Hi, does anyone have a working example of using

custom_info

field within

TaskExecutionEvent

to relay custom information about a task run?

Are you writing a plugin?

yeah, a Python plugin

ohhh, cc @Kevin Su instead of a python plugin, can we use Flyte Agent framework for this. from the python plugins (flytekit side) you cannot, but the agents you can

sorry, never mind, not writing a plugin, just need a way to send some custom information about a Task to using Flyte External Messages. Is this something that I can use

TaskExecutionEvent

and its

custom_info

field? And if so, how?

Ohh then use flytedeck

are flytedecks considered as external flyte messages (would something like

TaskExecutionEventRequest

have access to the task's deck)? or would I only be able to view the deck output through the flyte UI when reviewing specific runs?

Aah I get what you want now, ya flytedecks are html and you can view them programmatically, but that’s not right for you. In that case the only option is outputs - today flytekit cannot send events to FlyteAdmin

I see, thank you! What is the use case of `TaskExecutionEvent' ?

propeller send a event to update the task, workflow table. for example, update the status. we also send event to sqs, so you can write a consumer to read those events.

does any instance of the events get automatically sent to sqs? how does the event get sent when I call

TaskExecutionEvent

for example? And do I have any control over the destination of the event? Instead of sending to sqs can I send to Pub/Sub, for example?

yes, you can use gcp pub/sub as well. https://docs.flyte.org/en/latest/deployment/configuration/cloud_event.html#use-cases