Event triggers function operator

astronomer / airflow-provider-kafka

A provider package for kafka

Apache License 2.0

37 stars 16 forks source link

Event triggers function operator #17

Closed TJaniF closed 1 year ago

TJaniF commented 1 year ago

Triggering the function works, but not using the event information from the Kafka message. Putting this here to debug :)

dylanbstorey commented 1 year ago

@TJaniF - needed to just fix up some imports / work on the example dags a bit to get this working in repo with make dev. Please review. (Also i verified it works both for "function calls" and TriggerDagRunOperators)