[
https://issues.apache.org/jira/browse/AIRFLOW-2122?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=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 <module>
> [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)
