ephraimbuddy commented on issue #19096:
URL: https://github.com/apache/airflow/issues/19096#issuecomment-950888668


   The dag above doesn't appear on the UI and doesn't show import errors, 
probably needs modification. However, I saw the error from:
   ```
   from datetime import datetime
   from airflow.models import DAG
   
   
   dag = DAG("paramtest",
             start_date=datetime(2021, 1, 1),
             schedule_interval="@daily")
   
   
   @dag.task(params={"a": {1, 2, 3}, "b": {3, 4, 5}})
   def intersect(intersection):
       print(intersection)
   
   intersect("{{ params.a.intersection(params.b).pop() }}")
   ```
   
   


-- 
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