I have a transformer that Lists a set of companies in a database schema and then fires off a set of workflows. These end in 5 SQLExecutors which migrate the data into another database.
I want to be able to run a final tidy up process after these are all finished. The input must come from the List_Company_Schema process, not the SQLExectors but it must wait for them to finish.
How do I do this?
Best answer by nielsgerrits
Route from all outputports of transformers you want to wait for to a FeatureHolder. This will only release features if all have arrived. Then use a sampler to let only one feature through to initiate the next proces.
+61Route from all outputports of transformers you want to wait for to a FeatureHolder. This will only release features if all have arrived. Then use a sampler to let only one feature through to initiate the next proces.
@davebarter You need to get a Result from your 'Migrate_*' SQLExecutors. If you can add something like a SELECT COUNT(*) to those migrate SQL calls, then you'll know when each of those tasks finishes (the Initiator is output before the Result output so you can't use that). Then, a join of those four results with your Create_users (use FeatureMerger) should force the Create_users to wait for all the SQLExecutors to complete. Something along those lines.
