hi all, I have a task to call a client which used ...
# flyte-supportm
millions-summer-85484
08/30/2023, 4:42 AMhi all, I have a task to call a client which used to run the pipeline in certain platform, and I want to cancel the pipeline running when I click the terminate button in flyte UI, I have tried to use
atexistclinet.cancel_runningatexistmillions-summer-85484
08/30/2023, 4:47 AM Copy code
@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()t
tall-lock-23197
08/30/2023, 6:57 AM
@millions-summer-85484, since you want to terminate an execution that's running elsewhere, please make sure you're terminating it correctly. Is it working when you aren't including the same in a Flyte task?
f
freezing-airport-6809
08/30/2023, 2:41 PM
@millions-summer-85484 today we do not handle docker termination. https://docs.python.org/3/library/atexit.html
Hence it does not. Get invoked. You can contribute a signal handler to pyflyte-execute
m
millions-summer-85484
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. @freezing-airport-6809 I see, is there any other method to achieve the same effect?
f
freezing-airport-6809
08/30/2023, 5:47 PM
if you are simply calling external services, recommend Agents
t
tall-lock-23197
08/31/2023, 5:11 AM
2 Views