Aniruddha Sengupta
03/08/2022, 1:55 PMKevin Kho
03/08/2022, 2:20 PMAniruddha Sengupta
03/08/2022, 2:43 PMurl_extraction
which takes a lang
input. When the Flow is then created, it is mapped to a list of languages which creates a series of children tasks based on the language.
When I set the Flow's executor like so:
flow.executor = LocalDaskExecutor()
, this will ensure that the children tasks will be executed in parallel?
Thanks,
AniruddhaKevin Kho
03/08/2022, 2:48 PMAniruddha Sengupta
03/08/2022, 2:51 PMKevin Kho
03/08/2022, 2:51 PM