Is there a way to check the status and logs of a workflow submitted through hera?

[piby180]

Basically the title. I can create a workflow with Hera. But I can't check the current status or the logs for the workflow

[elliotgunton]

Hey @piby180! The status is part of the workflow object that you get back from the create method, you can check it like so:

hera/tests/submissions/test_hello_world.py

Lines 35 to 36 in 1567eae

	model_workflow = get_workflow().create(wait=True)
	assert model_workflow.status and model_workflow.status.phase == "Succeeded"

The logs can be fetched through the workflow_logs function on the WorkflowsService

hera/src/hera/workflows/service.py

Line 1056 in 1567eae

def workflow_logs(

Sorry for the delay, we had a busy ArgoCon/KubeCon last week!

[piby180]

Hi @elliotgunton
Thank you for your answer. I now understand that with wait=True, we create the workflow synchronously and when it is finished, we can get the status of the workflow.

But how do we get the status of a workflow which was created asynchronously?

[elliotgunton]

You will need the name and namespace of the workflow, then you can use this

hera/src/hera/workflows/service.py

Lines 991 to 997 in 23672c8

	def get_workflow(
	self,
	name: str,
	namespace: Optional[str] = None,
	resource_version: Optional[str] = None,
	fields: Optional[str] = None,
	) -> Workflow:

[piby180]

@elliotgunton Sorry for the delay. I was on vacation :)
Thanks and it is working now except logs.

I am not able to fetch the logs. My workflow is storing logs to S3 as an artifact.

from hera.workflows.service import WorkflowsService

s = WorkflowsService()
s.workflow_logs(name=wf_name)
---------------------------------------------------------------------------
KeyError                                  Traceback (most recent call last)
Cell In[93], line 1
----> 1 s.workflow_logs(name=wf_name)

File ~\AppData\Local\anaconda3\Lib\site-packages\hera\workflows\service.py:1105, in WorkflowsService.workflow_logs(self, name, namespace, pod_name, container, 
follow, previous, since_seconds, seconds, nanos, timestamps, tail_lines, limit_bytes, insecure_skip_tls_verify_backend, grep, selector)
   1102 if resp.ok:
   1103     return V1alpha1LogEntry(**resp.json())
-> 1105 raise exception_from_server_response(resp)

File ~\AppData\Local\anaconda3\Lib\site-packages\hera\exceptions\__init__.py:84, in exception_from_server_response(resp)
     80 assert not resp.ok, "This function should only be called with non-2xx responses"
     81 try:
     82     return exception_from_status_code(
     83         resp.status_code,
---> 84         f"Server returned status code {resp.status_code} with message: `{resp.json()['message']}`",
     85     )
     86 except json.JSONDecodeError:
     87     return exception_from_status_code(
     88         resp.status_code,
     89         f"Server returned status code {resp.status_code} with message: `{resp.text}`",
     90     )

KeyError: 'message'

I tried s.pod_logs(wf_name, pod_name) but got the same error.

My k8s role has permissions to read pod logs. Ideally I want to get the link to the log file on S3. Thanks for your help :)

apiVersion: rbac.authorization.k8s.io/v1
kind: Role
metadata:
  name: temp-argo-api-test
  namespace: argo-dev
rules:
  - apiGroups:
      - ""
    resources:
      - pods/logs
    verbs:
      - create
      - get
  - apiGroups:
      - argoproj.io
    resources:
      - workflows
      - workflowtaskresults
    verbs:
      - create
      - get
  - apiGroups:
      - argoproj.io
    resources:
      - workflowtemplates
    verbs:
      - get
    resourceNames: ["workflow-template-submittable"]