I am attempting to try using Deferrable opertators however, the example seem to be lacking info on where BaseTrigger and TriggerEvent are imported from. I cant seem to find info on the docs too
https://airflow.apache.org/docs/apache-airflow/stable/concepts/deferring.html?highlight=triggerevent
def __init__(self, moment):
super().__init__()
self.moment = moment
def serialize(self):
return ("airflow.triggers.temporal.DateTimeTrigger", {"moment": self.moment})
async def run(self):
while self.moment > timezone.utcnow():
await asyncio.sleep(1)
yield TriggerEvent(self.moment)
- Is
BaseTriggerthe same asairflow.models.trigger.Trigger?