obarisk commented on PR #55110:
URL: https://github.com/apache/airflow/pull/55110#issuecomment-3384441235

   by the way, before it got merged I'm currently using workaround like the 
following.
   patch that in the dag file which use the operators.
   
   ```python
   from dowhen import when
   
   def patch_logical_date(_frame):
     import pendulum # noqa
     context = _frame.f_locals.get("context", {})
     if not context:
       print("no context found")
     if context.get("logical_date") is None:
       context["logical_date"] = pendulum.now("UTC")
       _frame.f_locals["context"] = context
   
   when(
     GCSToBigQueryOperator.execute,
     """logical_date=context["logical_date"]"""
   ).do(patch_logical_date)
   ```


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: [email protected]

For queries about this service, please contact Infrastructure at:
[email protected]

Reply via email to