hi all, I have a task to call a client which used ...
# ask-the-communityy
Yue Shang
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_runningatexistYue Shang
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()s
Samhita Alla
08/30/2023, 6:57 AM
@Yue Shang, 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?
k
Ketan (kumare3)
08/30/2023, 2:41 PM
@Yue Shang 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
y
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?
k
Ketan (kumare3)
08/30/2023, 5:47 PM
if you are simply calling external services, recommend Agents
s
Samhita Alla
08/31/2023, 5:11 AM
2 Views