New RunLLM response generated:
>>>*# Question*
Hello folks π
I know that you can set a Sensor to poll for an S3 or SQS, but can Flyte accept a CloudEvent which would trigger a workflow or progress a workflow task? Being able to send a CloudEvent via HTTP ingress to Flyte to do this would be great (if we canβt do it, any idea what is involved?)
# Answer
Flyte does not natively support triggering workflows or progressing workflow tasks directly via CloudEvents sent through HTTP ingress. However, Flyte can emit CloudEvents to external systems like AWS SNS/SQS, GCP Pub/Sub, or Kafka, which can then be used to trigger workflows indirectly.
To achieve your goal, you would need to set up an intermediary service that listens for CloudEvents via HTTP ingress and then triggers the appropriate Flyte workflows or tasks. This service can use Flyte's REST API to start workflows or progress tasks based on the received CloudEvents.
Would you like more details on setting up such an intermediary service?
Sources:
-
Cloud Events - Flyte
-
Emit Other CloudEvents
Slack Link
https://flyte-org.slack.com/archives/CP2HDHKE1/p1723562188.503239 π 0 button π 0 button π‘
Hint: Mention @runllm in the thread for followups.