https://prefect.io logo
Title
s

shazard

04/10/2020, 7:26 AM
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 ?
Adding a sleep command in the task does not seem to change the behavior.
j

josh

04/10/2020, 12:28 PM
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?
s

shazard

04/10/2020, 12:33 PM
Hi ! Yeah, that does work. Where does this come from ?
j

josh

04/10/2020, 12:47 PM
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
s

shazard

04/10/2020, 12:54 PM
Great if it is already fixed then ! Thanks for the input !