@here Hi
I have a query regarding context when I t...
# prefect-communitys
sravani jammula
07/12/2022, 3:52 PM@here Hi
I have a query regarding context when I try to use the following content in message block ,I'm seeing error "ERROR | Unexpected error occured in FlowRunner: AttributeError("'Context' object has no attribute 'task_name'")
I tried to import context library as well but it is saying it is not used not sure what wrong I'm doing here
Content in message block : f"The task
{prefect.context.task_name}k
Kevin Kho
07/12/2022, 3:56 PM
Hey Sravani, no need to tag here (though I think it’s not supported anyway). We’ll respond when we see the message. Are you doing this inside a task?
s
sravani jammula
07/12/2022, 3:58 PMThis I'm trying in function called "post_to_slack_on_failure"
k
Kevin Kho
07/12/2022, 4:04 PM
Could you show me some sample code?
s
sravani jammula
07/12/2022, 4:07 PMk
Kevin Kho
07/12/2022, 4:12 PM
This looks right. How do you call the function? Do you pass it as a state handler?
s
sravani jammula
07/12/2022, 4:13 PMyeah
sravani jammula
07/12/2022, 4:13 PMin flow
sravani jammula
07/12/2022, 4:14 PMt = task(state_handlers=[post_to_slack_on_failure])
with Flow(FLOW_NAME, storage=STORAGE, state_handlers=[post_to_slack_on_failure], run_config=KubernetesRun(labels=["REGION"])) as flow:
k
Kevin Kho
07/12/2022, 4:15 PM
This looks right. Could you give me an end to end example?
s
sravani jammula
07/12/2022, 4:16 PMend to end you mean
I'm trying to create a k8s job and send the notifications on task failure to slack
k
Kevin Kho
07/12/2022, 4:18 PM
No need for the k8s part. Just a full script with flow.run that raises the error
s
sravani jammula
07/12/2022, 4:21 PMsravani jammula
07/12/2022, 4:22 PMignore the unsed lines
k
Kevin Kho
07/12/2022, 4:23 PM
Ah I understand. You attached the state handler to the Flow so it’s not running in a task so there is no task name.
Kevin Kho
07/12/2022, 4:23 PM
You need to attach it to the task state handler instead
s
sravani jammula
07/12/2022, 4:23 PMcan you show the sample code
k
Kevin Kho
07/12/2022, 4:24 PM
Copy code
@task(state_handlers=[mystatehandler])Kevin Kho
07/12/2022, 4:24 PM
Attach it there instead of the Flow
s
sravani jammula
07/12/2022, 4:24 PMI think I tried that as well
sravani jammula
07/12/2022, 4:24 PMlet me retry
sravani jammula
07/12/2022, 4:26 PMthis(@task(state_handlers=[mystatehandler])) where should I put the code
k
Kevin Kho
07/12/2022, 4:52 PM
You need to remove it from the flow side
s
sravani jammula
07/12/2022, 6:48 PMif I remove from the flow side ,statehandler is not sending msg to slack channel
sravani jammula
07/12/2022, 6:48 PMwith Flow(FLOW_NAME, storage=STORAGE, run_config=KubernetesRun(labels=["REGION"])) as flow: