You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airflow.apache.org by "ASF subversion and git services (JIRA)" <ji...@apache.org> on 2017/01/09 20:46:58 UTC

[jira] [Commented] (AIRFLOW-728) Google Bigquery table exists sensor

    [ https://issues.apache.org/jira/browse/AIRFLOW-728?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15812801#comment-15812801 ] 

ASF subversion and git services commented on AIRFLOW-728:
---------------------------------------------------------

Commit 617ba741205ddea8461fc287267fc9c371ace2de in incubator-airflow's branch refs/heads/master from [~bodschut]
[ https://git-wip-us.apache.org/repos/asf?p=incubator-airflow.git;h=617ba74 ]

[AIRFLOW-728] Add Google BigQuery table sensor

Design a sensor that checks whether a certain
table is present in bigquery. The sensor will
accept the google cloud project id, bigquery
dataset id and bigquery table id to check as
parameters.

Internally, it will use the bigquery hook to check
for the existence of the table.
Therefore a 'table_exists' method will be added to
the existing Bigquery hook.

Closes #1970 from bodschut/feature/bq_sensor


> Google Bigquery table exists sensor
> -----------------------------------
>
>                 Key: AIRFLOW-728
>                 URL: https://issues.apache.org/jira/browse/AIRFLOW-728
>             Project: Apache Airflow
>          Issue Type: New Feature
>          Components: gcp
>            Reporter: Bob De Schutter
>            Assignee: Bob De Schutter
>   Original Estimate: 2h
>  Remaining Estimate: 2h
>
> Design a sensor that checks whether a certain table is present in bigquery. The sensor will accept the google cloud project id, bigquery dataset id and bigquery table id to check as parameters.
> Internally, it will use the bigquery hook to check for the existence of the table. Therefore a 'table_exists' method will be added to the existing Bigquery hook.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)