You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airflow.apache.org by ms...@apache.org on 2017/10/23 08:41:43 UTC
incubator-airflow git commit: [AIRFLOW-1677] Fix typo in
example_qubole_operator
Repository: incubator-airflow
Updated Branches:
refs/heads/master 21257e8f0 -> 4386cd414
[AIRFLOW-1677] Fix typo in example_qubole_operator
Closes #2661 from rupesh92/AIRFLOW-1677
Project: http://git-wip-us.apache.org/repos/asf/incubator-airflow/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-airflow/commit/4386cd41
Tree: http://git-wip-us.apache.org/repos/asf/incubator-airflow/tree/4386cd41
Diff: http://git-wip-us.apache.org/repos/asf/incubator-airflow/diff/4386cd41
Branch: refs/heads/master
Commit: 4386cd4145c15f03c61911d1c24c698d00db25b1
Parents: 21257e8
Author: Rupesh Bansal <ru...@qubole.com>
Authored: Mon Oct 23 14:09:10 2017 +0530
Committer: Sumit Maheshwari <su...@gmail.com>
Committed: Mon Oct 23 14:10:06 2017 +0530
----------------------------------------------------------------------
airflow/contrib/example_dags/example_qubole_operator.py | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-airflow/blob/4386cd41/airflow/contrib/example_dags/example_qubole_operator.py
----------------------------------------------------------------------
diff --git a/airflow/contrib/example_dags/example_qubole_operator.py b/airflow/contrib/example_dags/example_qubole_operator.py
index bf32788..03ba1dd 100644
--- a/airflow/contrib/example_dags/example_qubole_operator.py
+++ b/airflow/contrib/example_dags/example_qubole_operator.py
@@ -12,6 +12,7 @@
# See the License for the specific language governing permissions and
# limitations under the License.
+import airflow
from airflow import DAG
from airflow.operators.dummy_operator import DummyOperator
from airflow.operators.python_operator import PythonOperator, BranchPythonOperator
@@ -24,7 +25,7 @@ import random
default_args = {
'owner': 'airflow',
'depends_on_past': False,
- 'start_date': airflow.utils.dates.days_ago(2)
+ 'start_date': airflow.utils.dates.days_ago(2),
'email': ['airflow@example.com'],
'email_on_failure': False,
'email_on_retry': False