[jira] [Commented] (AIRFLOW-2122) SSHOperator throws an error
[ https://issues.apache.org/jira/browse/AIRFLOW-2122?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16474726#comment-16474726 ] ASF subversion and git services commented on AIRFLOW-2122: -- Commit 6c19468e0b3b938249acc43e4b833a753d093efc in incubator-airflow's branch refs/heads/master from alberto.calderari [ https://git-wip-us.apache.org/repos/asf?p=incubator-airflow.git;h=6c19468 ] [AIRFLOW-2110][AIRFLOW-2122] Enhance Http Hook - Use a header in passed in the "extra" argument and add tenacity retry - Fix the tests with proper mocking Closes #3071 from albertocalderari/master > SSHOperator throws an error > --- > > Key: AIRFLOW-2122 > URL: https://issues.apache.org/jira/browse/AIRFLOW-2122 > Project: Apache Airflow > Issue Type: Bug >Reporter: sam sen >Priority: Major > Fix For: 2.0.0 > > > Here's my code: > {code:java} > dag = DAG('transfer_ftp_s3', > default_args=default_args,schedule_interval=None) }} > task = SSHOperator(ssh_conn_id='ssh_node', > task_id="check_ftp_for_new_files", > command="echo 'hello world'", > do_xcom_push=True, dag=dag,) > {code} > > Here's the error > {code:java} > [2018-02-19 06:48:02,691] {{base_task_runner.py:98}} INFO - Subtask: > Traceback (most recent call last): > [2018-02-19 06:48:02,691] {{base_task_runner.py:98}} INFO - Subtask: File > "/usr/bin/airflow", line 27, in > [2018-02-19 06:48:02,692] {{base_task_runner.py:98}} INFO - Subtask: > args.func(args) > [2018-02-19 06:48:02,693] {{base_task_runner.py:98}} INFO - Subtask: File > "/usr/lib/python2.7/site-packages/airflow/bin/cli.py", line 392, in run > [2018-02-19 06:48:02,695] {{base_task_runner.py:98}} INFO - Subtask: > pool=args.pool, > [2018-02-19 06:48:02,695] {{base_task_runner.py:98}} INFO - Subtask: File > "/usr/lib/python2.7/site-packages/airflow/utils/db.py", line 50, in wrapper > [2018-02-19 06:48:02,696] {{base_task_runner.py:98}} INFO - Subtask: > result = func(*args, **kwargs) > [2018-02-19 06:48:02,696] {{base_task_runner.py:98}} INFO - Subtask: File > "/usr/lib/python2.7/site-packages/airflow/models.py", line 1496, in > _run_raw_task > [2018-02-19 06:48:02,696] {{base_task_runner.py:98}} INFO - Subtask: > result = task_copy.execute(context=context) > [2018-02-19 06:48:02,697] {{base_task_runner.py:98}} INFO - Subtask: File > "/usr/lib/python2.7/site-packages/airflow/contrib/operators/ssh_operator.py", > line 146, in execute > [2018-02-19 06:48:02,697] {{base_task_runner.py:98}} INFO - Subtask: > raise AirflowException("SSH operator error: {0}".format(str(e))) > [2018-02-19 06:48:02,698] {{base_task_runner.py:98}} INFO - Subtask: > airflow.exceptions.AirflowException: SSH operator error: 'bool' object has no > attribute 'lower' > {code} > > -- This message was sent by Atlassian JIRA (v7.6.3#76005)
[jira] [Commented] (AIRFLOW-2122) SSHOperator throws an error
[ https://issues.apache.org/jira/browse/AIRFLOW-2122?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16375593#comment-16375593 ] ASF subversion and git services commented on AIRFLOW-2122: -- Commit af1f9bcaa808b9f1772dfd222c8d37755810275e in incubator-airflow's branch refs/heads/master from [~sreenath.kamath] [ https://git-wip-us.apache.org/repos/asf?p=incubator-airflow.git;h=af1f9bc ] [AIRFLOW-2122] Handle boolean values in sshHook This allows passing boolean values in the extra field of ssh connection Closes #3070 from sreenathkamath/AIRFLOW-2122 > SSHOperator throws an error > --- > > Key: AIRFLOW-2122 > URL: https://issues.apache.org/jira/browse/AIRFLOW-2122 > Project: Apache Airflow > Issue Type: Bug >Reporter: sam sen >Priority: Major > Fix For: 2.0.0 > > > Here's my code: > {code:java} > dag = DAG('transfer_ftp_s3', > default_args=default_args,schedule_interval=None) }} > task = SSHOperator(ssh_conn_id='ssh_node', > task_id="check_ftp_for_new_files", > command="echo 'hello world'", > do_xcom_push=True, dag=dag,) > {code} > > Here's the error > {code:java} > [2018-02-19 06:48:02,691] {{base_task_runner.py:98}} INFO - Subtask: > Traceback (most recent call last): > [2018-02-19 06:48:02,691] {{base_task_runner.py:98}} INFO - Subtask: File > "/usr/bin/airflow", line 27, in > [2018-02-19 06:48:02,692] {{base_task_runner.py:98}} INFO - Subtask: > args.func(args) > [2018-02-19 06:48:02,693] {{base_task_runner.py:98}} INFO - Subtask: File > "/usr/lib/python2.7/site-packages/airflow/bin/cli.py", line 392, in run > [2018-02-19 06:48:02,695] {{base_task_runner.py:98}} INFO - Subtask: > pool=args.pool, > [2018-02-19 06:48:02,695] {{base_task_runner.py:98}} INFO - Subtask: File > "/usr/lib/python2.7/site-packages/airflow/utils/db.py", line 50, in wrapper > [2018-02-19 06:48:02,696] {{base_task_runner.py:98}} INFO - Subtask: > result = func(*args, **kwargs) > [2018-02-19 06:48:02,696] {{base_task_runner.py:98}} INFO - Subtask: File > "/usr/lib/python2.7/site-packages/airflow/models.py", line 1496, in > _run_raw_task > [2018-02-19 06:48:02,696] {{base_task_runner.py:98}} INFO - Subtask: > result = task_copy.execute(context=context) > [2018-02-19 06:48:02,697] {{base_task_runner.py:98}} INFO - Subtask: File > "/usr/lib/python2.7/site-packages/airflow/contrib/operators/ssh_operator.py", > line 146, in execute > [2018-02-19 06:48:02,697] {{base_task_runner.py:98}} INFO - Subtask: > raise AirflowException("SSH operator error: {0}".format(str(e))) > [2018-02-19 06:48:02,698] {{base_task_runner.py:98}} INFO - Subtask: > airflow.exceptions.AirflowException: SSH operator error: 'bool' object has no > attribute 'lower' > {code} > > -- This message was sent by Atlassian JIRA (v7.6.3#76005)
[jira] [Commented] (AIRFLOW-2122) SSHOperator throws an error
[ https://issues.apache.org/jira/browse/AIRFLOW-2122?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16375594#comment-16375594 ] ASF subversion and git services commented on AIRFLOW-2122: -- Commit af1f9bcaa808b9f1772dfd222c8d37755810275e in incubator-airflow's branch refs/heads/master from [~sreenath.kamath] [ https://git-wip-us.apache.org/repos/asf?p=incubator-airflow.git;h=af1f9bc ] [AIRFLOW-2122] Handle boolean values in sshHook This allows passing boolean values in the extra field of ssh connection Closes #3070 from sreenathkamath/AIRFLOW-2122 > SSHOperator throws an error > --- > > Key: AIRFLOW-2122 > URL: https://issues.apache.org/jira/browse/AIRFLOW-2122 > Project: Apache Airflow > Issue Type: Bug >Reporter: sam sen >Priority: Major > Fix For: 2.0.0 > > > Here's my code: > {code:java} > dag = DAG('transfer_ftp_s3', > default_args=default_args,schedule_interval=None) }} > task = SSHOperator(ssh_conn_id='ssh_node', > task_id="check_ftp_for_new_files", > command="echo 'hello world'", > do_xcom_push=True, dag=dag,) > {code} > > Here's the error > {code:java} > [2018-02-19 06:48:02,691] {{base_task_runner.py:98}} INFO - Subtask: > Traceback (most recent call last): > [2018-02-19 06:48:02,691] {{base_task_runner.py:98}} INFO - Subtask: File > "/usr/bin/airflow", line 27, in > [2018-02-19 06:48:02,692] {{base_task_runner.py:98}} INFO - Subtask: > args.func(args) > [2018-02-19 06:48:02,693] {{base_task_runner.py:98}} INFO - Subtask: File > "/usr/lib/python2.7/site-packages/airflow/bin/cli.py", line 392, in run > [2018-02-19 06:48:02,695] {{base_task_runner.py:98}} INFO - Subtask: > pool=args.pool, > [2018-02-19 06:48:02,695] {{base_task_runner.py:98}} INFO - Subtask: File > "/usr/lib/python2.7/site-packages/airflow/utils/db.py", line 50, in wrapper > [2018-02-19 06:48:02,696] {{base_task_runner.py:98}} INFO - Subtask: > result = func(*args, **kwargs) > [2018-02-19 06:48:02,696] {{base_task_runner.py:98}} INFO - Subtask: File > "/usr/lib/python2.7/site-packages/airflow/models.py", line 1496, in > _run_raw_task > [2018-02-19 06:48:02,696] {{base_task_runner.py:98}} INFO - Subtask: > result = task_copy.execute(context=context) > [2018-02-19 06:48:02,697] {{base_task_runner.py:98}} INFO - Subtask: File > "/usr/lib/python2.7/site-packages/airflow/contrib/operators/ssh_operator.py", > line 146, in execute > [2018-02-19 06:48:02,697] {{base_task_runner.py:98}} INFO - Subtask: > raise AirflowException("SSH operator error: {0}".format(str(e))) > [2018-02-19 06:48:02,698] {{base_task_runner.py:98}} INFO - Subtask: > airflow.exceptions.AirflowException: SSH operator error: 'bool' object has no > attribute 'lower' > {code} > > -- This message was sent by Atlassian JIRA (v7.6.3#76005)
[jira] [Commented] (AIRFLOW-2122) SSHOperator throws an error
[ https://issues.apache.org/jira/browse/AIRFLOW-2122?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16369146#comment-16369146 ] sam sen commented on AIRFLOW-2122: -- That did it!!! Thanks > SSHOperator throws an error > --- > > Key: AIRFLOW-2122 > URL: https://issues.apache.org/jira/browse/AIRFLOW-2122 > Project: Apache Airflow > Issue Type: Bug >Reporter: sam sen >Priority: Major > > Here's my code: > {code:java} > dag = DAG('transfer_ftp_s3', > default_args=default_args,schedule_interval=None) }} > task = SSHOperator(ssh_conn_id='ssh_node', > task_id="check_ftp_for_new_files", > command="echo 'hello world'", > do_xcom_push=True, dag=dag,) > {code} > > Here's the error > {code:java} > [2018-02-19 06:48:02,691] {{base_task_runner.py:98}} INFO - Subtask: > Traceback (most recent call last): > [2018-02-19 06:48:02,691] {{base_task_runner.py:98}} INFO - Subtask: File > "/usr/bin/airflow", line 27, in > [2018-02-19 06:48:02,692] {{base_task_runner.py:98}} INFO - Subtask: > args.func(args) > [2018-02-19 06:48:02,693] {{base_task_runner.py:98}} INFO - Subtask: File > "/usr/lib/python2.7/site-packages/airflow/bin/cli.py", line 392, in run > [2018-02-19 06:48:02,695] {{base_task_runner.py:98}} INFO - Subtask: > pool=args.pool, > [2018-02-19 06:48:02,695] {{base_task_runner.py:98}} INFO - Subtask: File > "/usr/lib/python2.7/site-packages/airflow/utils/db.py", line 50, in wrapper > [2018-02-19 06:48:02,696] {{base_task_runner.py:98}} INFO - Subtask: > result = func(*args, **kwargs) > [2018-02-19 06:48:02,696] {{base_task_runner.py:98}} INFO - Subtask: File > "/usr/lib/python2.7/site-packages/airflow/models.py", line 1496, in > _run_raw_task > [2018-02-19 06:48:02,696] {{base_task_runner.py:98}} INFO - Subtask: > result = task_copy.execute(context=context) > [2018-02-19 06:48:02,697] {{base_task_runner.py:98}} INFO - Subtask: File > "/usr/lib/python2.7/site-packages/airflow/contrib/operators/ssh_operator.py", > line 146, in execute > [2018-02-19 06:48:02,697] {{base_task_runner.py:98}} INFO - Subtask: > raise AirflowException("SSH operator error: {0}".format(str(e))) > [2018-02-19 06:48:02,698] {{base_task_runner.py:98}} INFO - Subtask: > airflow.exceptions.AirflowException: SSH operator error: 'bool' object has no > attribute 'lower' > {code} > > -- This message was sent by Atlassian JIRA (v7.6.3#76005)