You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airflow.apache.org by "Jithin Sukumar (Jira)" <ji...@apache.org> on 2020/01/22 11:58:00 UTC

[jira] [Updated] (AIRFLOW-6583) (BigQuery) Add query_params to templated_fields

     [ https://issues.apache.org/jira/browse/AIRFLOW-6583?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Jithin Sukumar updated AIRFLOW-6583:
------------------------------------
    Description: 
To query time-partitioned tables, I am passing {{query_params}} like this
 yesterday = Variable.get('yesterday', '{{{{yesterday_ds}}}}')
 today = Variable.get('today', '{{{{ds}}}}')
 ...
 query_params=[{'name': 'yesterday', 'parameterType':

{'type': 'STRING'}

,
 'parameterValue': \{'value': yesterday}},
 {'name': 'today', 'parameterType':

{'type': 'STRING'}

,
 'parameterValue': \{'value': today}}]
 query_params needs to be a template_field

  was:
To query time-partitioned tables, I am passing \{{query_params}} like this
yesterday = Variable.get('yesterday', '\{{yesterday_ds}}')
today = Variable.get('today', '\{{ds}}')
...
query_params=[\{'name': 'yesterday', 'parameterType': {'type': 'STRING'},
                       'parameterValue': \{'value': yesterday}},
                      \{'name': 'today', 'parameterType': {'type': 'STRING'},
                       'parameterValue': \{'value': today}}]
query_params needs to be a template_field


> (BigQuery) Add query_params to templated_fields
> -----------------------------------------------
>
>                 Key: AIRFLOW-6583
>                 URL: https://issues.apache.org/jira/browse/AIRFLOW-6583
>             Project: Apache Airflow
>          Issue Type: New Feature
>          Components: gcp
>    Affects Versions: 1.10.7
>            Reporter: Jithin Sukumar
>            Assignee: Jithin Sukumar
>            Priority: Minor
>             Fix For: 2.0.0
>
>
> To query time-partitioned tables, I am passing {{query_params}} like this
>  yesterday = Variable.get('yesterday', '{{{{yesterday_ds}}}}')
>  today = Variable.get('today', '{{{{ds}}}}')
>  ...
>  query_params=[{'name': 'yesterday', 'parameterType':
> {'type': 'STRING'}
> ,
>  'parameterValue': \{'value': yesterday}},
>  {'name': 'today', 'parameterType':
> {'type': 'STRING'}
> ,
>  'parameterValue': \{'value': today}}]
>  query_params needs to be a template_field



--
This message was sent by Atlassian Jira
(v8.3.4#803005)