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