shazard
04/10/2020, 7:26 AM@task
def dummy_task(param):
pass
with Flow("test") as flow:
dummy_task.map(list(range(100)))
flow.run()
flow.register()
This code does run correctly locally, but gets stuck running the 64th task when manually ran from the Core Server UI.
Since it always gets stuck on the same task I suppose this has to do with some resource or process limit but I can't seem to point exactly what it can be.
Any idea ?josh
04/10/2020, 12:28 PM--show-flow-logs
flag does the flow succeed?shazard
04/10/2020, 12:33 PMjosh
04/10/2020, 12:47 PMmaster
branch and will be out in the 0.10.2
releaseshazard
04/10/2020, 12:54 PM