airflow-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "sam sen (JIRA)" <j...@apache.org>
Subject [jira] [Created] (AIRFLOW-2122) SSHOperator throws an error
Date Mon, 19 Feb 2018 06:59:00 GMT
sam sen created AIRFLOW-2122:
--------------------------------

             Summary: 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


Here's my code:

 

 

{{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,)}}

 

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)

Mime
View raw message