You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airflow.apache.org by GitBox <gi...@apache.org> on 2022/10/05 19:55:31 UTC

[GitHub] [airflow] EssKayz commented on issue #26619: 2.4.0 : Dynamic Task Mapping - Assigning multiple parameters to a PythonOperator

EssKayz commented on issue #26619:
URL: https://github.com/apache/airflow/issues/26619#issuecomment-1264676637

   Still not exactly sure how to get that to work, unsure if I understood the suggestion wrong, but at least done in a similar way as with PythonOperators, no task is generated to the DAG
   ```
   from airflow.decorators import task
   
   def get_data_from_db(table_name, **kwargs):
   
       @task(task_id=f'get_db_{table_name}')
       def get_db_objects(**kwargs):
           return {}
   
   
   with dag:
       test_task = get_data_from_db(
           table_name='person'
       )
   
   ```
   
   
   


-- 
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: commits-unsubscribe@airflow.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org