You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@airflow.apache.org by "Aleksander Nitecki (Jira)" <ji...@apache.org> on 2020/03/03 14:42:00 UTC

[jira] [Created] (AIRFLOW-6978) Add PubSubPullOperator

Aleksander Nitecki created AIRFLOW-6978:
-------------------------------------------

             Summary: Add PubSubPullOperator
                 Key: AIRFLOW-6978
                 URL: https://issues.apache.org/jira/browse/AIRFLOW-6978
             Project: Apache Airflow
          Issue Type: Improvement
          Components: gcp, operators
    Affects Versions: 2.0.0
            Reporter: Aleksander Nitecki


Add PubSubPullOperator - a non-blocking equivalent to Add PubSubPullSensor.

These two share most of functionality but ultimately serve different purpose - while existing PubSubPullSensor will block the pipeline until it receives a message, new PubSubPullOperator can be used to check for new messages opportunistically.



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