Yue Shang
08/30/2023, 4:42 AMatexist
to register clinet.cancel_running
in the task, but termination of flyte workflow does not call atexist
somehow, anyone knows why and how to fix? thanks!@task()
def client_task():
import Client
client = Client()
client.execute_flow("a", "b")
execid = client.execid
import atexit
atexit.register(client.cancel_execution, execid)
@workflow
def azkaban_client_workflow() -> None:
azkaban_client_task()
Samhita Alla
Ketan (kumare3)
Yue Shang
08/30/2023, 4:05 PMIs it working when you aren't including the same in a Flyte task?it's working when I explicitly call the method of canceling. @Ketan (kumare3) I see, is there any other method to achieve the same effect?
Ketan (kumare3)
Samhita Alla