Replies: 1 comment
-
I tried the following workaround to forcefully terminating an Argo run and it worked out well: directly deleting the running pods with the matching workflow run label on the Kubernetes cluster. E.g. Ended up with a better solution: |
Beta Was this translation helpful? Give feedback.
0 replies
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
Uh oh!
There was an error while loading. Please reload this page.
Uh oh!
There was an error while loading. Please reload this page.
-
I am working on a KFP (Kubeflow Pipeline) deployment backed by Argo Workflows v3.4.
A workflow run cannot be terminated either via KFP API or via Argo API or via kubectl directly on the Argo workflow.
I tried the following and got no error (none regarding params, access permission, etc) from the client API calls or the kubectl commands, yet the Argo workflow simply didn't stop and keep running. After the current step is completed, the workflow has Phase=Failed and no further steps is executed.
1] KFP client API:
kfpRunClient.TerminateRun
This actually patches activeDeadlineSeconds=0 to the Argo workflow, as I can see from
kubectl describe workflow
.2] Argo client API:
I tried combination of activeDeadlineSeconds and/or shutdown.
Tried without the
Force
option.Tried with activeDeadlineSeconds=1 or activeDeadlineSeconds=10.
3] kubectl command:
Then I checked by
kubectl describe workflow
and confirmed that the expected patches were already in the workflow run.From the above output for the workflow I didn't see any event related to the termination request.
I can successfully delete the running workflow, however I worry the automatic archiving of pod logs will be lost.
I don't have the option to upgrade the KFP and Argo Workflows at this time though.
I noticed there is another deployment with Argo Workflows v3.6 and the activeDeadlineSeconds=0 patch works well to terminate the workflow immediately.
Can you pls help on other options that I might try with?
Or should I look into any of the Argo Workflows configuration/configmap?
Beta Was this translation helpful? Give feedback.
All reactions