BhuviTheDataGuy opened a new issue #11822:
URL: https://github.com/apache/airflow/issues/11822
I have a SQL file like below.
```sql
select * from {{params.table_name }} where data > {{ params.maxdt }}
```
And Im calling a function from python operator. So I need to pass maxdt
value while calling that python operator.
```py
class SQLTemplatedPythonOperator(PythonOperator):
template_ext = ('.sql',)
table_list = [public.t1]
for table_name in table_list:
pull = SQLTemplatedPythonOperator(
task_id='export_{}'.format(table_name),dag=dag,
templates_dict={'query': 'public.t1.sql'},
params = {'table_name': table_name, 'maxdt':
{{ti.xcom_pull(task_ids='push_result_{}')}}.format(table_name)},
op_kwargs={'tablename':table_name},
python_callable=pgexport,
provide_context=True,
)
```
There was a task called `push_result_{}.format(table_name)` do some process
and push a data value to **xcom**. Now here I need to get that value and pass
it inside my pull task. So my SQL templated query will get the value and pass
it to the pgexport function.
**pgexport** - it will use postgrestogcs operator to push the results of the
templated SQL query.
Unfortunately, the syntax I used is not working.
----------------------------------------------------------------
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.
For queries about this service, please contact Infrastructure at:
[email protected]
