my ($self) = @_;
return [
{ -logic_name => 'find_files',
-module => 'Bio::EnsEMBL::Hive::RunnableDB::JobFactory',
-parameters => {
'inputcmd' => 'find #directory# -type f',
'column_names' => [ 'filename' ],
},
-flow_into => {
2 => [ 'compress_a_file' ], # will create a fan of jobs
},
},
{ -logic_name => 'compress_a_file',
-module => 'Bio::EnsEMBL::Hive::RunnableDB::SystemCmd',
-parameters => {
'cmd' => 'gzip #filename#',
},
-analysis_capacity => 4, # limit the number of workers that will be performing jobs in parallel
},
];
}