Hello there ! Would there be any reason explaining why a flow does not generate all mapped tasks it should ?

@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 ?

Hey @shazard I think I know what might be the problem. If you run your agent with the

--show-flow-logs

flag does the flow succeed?

Hi ! Yeah, that does work. Where does this come from ?

There’s a bug in the current release with output overloading the buffer of the subprocess. The fix is in the

master

branch and will be out in the

0.10.2

release

Great if it is already fixed then ! Thanks for the input !