Fernando Diaz
03/29/2022, 10:17 AMbigqueryjob
). We see in the logs that the node timeouts as expected:
"Current execution for the node timed out; timeout configured: 3h0m0s"
However, the Delete
method of the plugin (https://github.com/flyteorg/flyteplugins/blob/master/go/tasks/plugins/webapi/bigquery/plugin.go#L226) is never called after the timeout, so the job is not cancelled. Is this expected? How can I tell propeller to abort the node after a timeout?// Delete the object in the remote service using the resource key. Flyte will call this API at least once. If the
// resource has already been deleted, the API should not fail.
https://pkg.go.dev/github.com/lyft/flyteplugins@v0.5.26/go/tasks/pluginmachinery/webapi#AsyncPlugin
So we would’ve expected propeller to call this method after a time out.Dan Rammer (hamersaw)
03/29/2022, 10:41 AMFernando Diaz
03/29/2022, 11:46 AMDan Rammer (hamersaw)
03/29/2022, 3:57 PM