Shabbir Suterwala
03/22/2024, 7:57 PMmap_task()
, however the workers (due to the DAG nature of flyte workflow) have to wait until the chunking finishes.
What is a good pattern to do this via Flyte?.
Thanks for your help!Ketan (kumare3)
word length
and word length histogram
to one python function, or you prefer not toKetan (kumare3)
Ketan (kumare3)
workflows
/ launchplans
and we will be delivering this later. But would love to understand if you can work with this limitation todayKetan (kumare3)
Shabbir Suterwala
03/23/2024, 3:05 AMmap_task()
to distribute the work on "workers", however that is not the ask here. The ask is to spin up N consumers and M producers that communicate over a queue.Ketan (kumare3)