airflow-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "ASF subversion and git services (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (AIRFLOW-1913) Add Delete Operator for GCP Pub/Sub Topics and Create/Delete Operator for Subscriptions
Date Mon, 18 Dec 2017 22:55:00 GMT

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

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

Commit 8942d2e848b0df1b4c7868451f6815af5ae0fa8b in incubator-airflow's branch refs/heads/master
from [~prodonjs]
[ https://git-wip-us.apache.org/repos/asf?p=incubator-airflow.git;h=8942d2e ]

[AIRFLOW-1913] Add new GCP PubSub operators

Closes #2872 from prodonjs/master


> Add Delete Operator for GCP Pub/Sub Topics and Create/Delete Operator for Subscriptions
> ---------------------------------------------------------------------------------------
>
>                 Key: AIRFLOW-1913
>                 URL: https://issues.apache.org/jira/browse/AIRFLOW-1913
>             Project: Apache Airflow
>          Issue Type: Improvement
>          Components: contrib, gcp, hooks
>    Affects Versions: Airflow 1.8
>            Reporter: Jason Prodonovich
>            Assignee: Jason Prodonovich
>             Fix For: 1.10.0
>
>   Original Estimate: 72h
>  Remaining Estimate: 72h
>
> There have been requests for Operators that pull messages from Google Cloud Pub/Sub and
then act upon the receipt of those messages. In order to facilitate that, additional PubSub
Operators must be added to handle creation and deletion of both topics and subscriptions.
This will allow for Workflows and end-to-end tests to perform all of the necessary setup and
cleanup when wishing to subscribe and process messages from a topic.
> A subsequent issue will be created for the Pull and Acknowledge Operators.



--
This message was sent by Atlassian JIRA
(v6.4.14#64029)

Mime
View raw message