Nikita Samoylov
12/22/2021, 8:50 AMCancel
and Set state
options in UI for each running flow.
• If I press Cancel
- flow is stuck in Cancelling status forever and what is more dangerous for us child process on agent machine which actually executed this flow is stuck too and is never killed. It means it does not release resources. I can see 2 processes stuck (as on picture) - 1 for flow execution and 1 for it's heartbeat.
• Setting Failed
state seems working well, but not if I set state after flow is cancelled.
Could you tell me something about this behaviour ?
PS: I'm talking about Cloud backend + Local AgentAnna Geller
12/22/2021, 10:33 AMNikita Samoylov
12/22/2021, 12:29 PMfrom time import sleep
from prefect import Flow, task
from prefect.executors import LocalDaskExecutor
@task()
def sleep_task():
sleep(30)
with Flow(name='train-flow') as flow:
sleep_task()
if __name__ == '__main__':
flow.executor = LocalDaskExecutor(scheduler='processes', num_workers=8)
flow.register(project_name='pLTV-debug')
But it works fine with LocalExecutor for example.
I think 2nd and 3rd your questions are not relevant anymore.
I will appreciate any updates about this problem.Anna Geller
12/22/2021, 12:36 PM