Repository: incubator-airflow Updated Branches: refs/heads/master 084bc9136 -> 62b95f8bc
[AIRFLOW-2498] Fix Unexpected argument in SFTP Sensor - The SFTP sensor is using SFTP hook and passing `sftp_conn_id` to `sftp_conn_id` parameter which doesn't exist. The solution would be to remove the parameter name, hence defaulting to first parameter which in this case would be `ftp_conn_id` Closes #3392 from kaxil/AIRFLOW-2498 Project: http://git-wip-us.apache.org/repos/asf/incubator-airflow/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-airflow/commit/62b95f8b Tree: http://git-wip-us.apache.org/repos/asf/incubator-airflow/tree/62b95f8b Diff: http://git-wip-us.apache.org/repos/asf/incubator-airflow/diff/62b95f8b Branch: refs/heads/master Commit: 62b95f8bce2fbad492104043f557495e474c02f4 Parents: 084bc91 Author: Kaxil Naik <kaxiln...@gmail.com> Authored: Wed May 23 13:09:34 2018 +0100 Committer: Kaxil Naik <kaxiln...@apache.org> Committed: Wed May 23 13:09:34 2018 +0100 ---------------------------------------------------------------------- airflow/contrib/sensors/sftp_sensor.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-airflow/blob/62b95f8b/airflow/contrib/sensors/sftp_sensor.py ---------------------------------------------------------------------- diff --git a/airflow/contrib/sensors/sftp_sensor.py b/airflow/contrib/sensors/sftp_sensor.py index 801943a..51ad11d 100644 --- a/airflow/contrib/sensors/sftp_sensor.py +++ b/airflow/contrib/sensors/sftp_sensor.py @@ -38,7 +38,7 @@ class SFTPSensor(BaseSensorOperator): def __init__(self, path, sftp_conn_id='sftp_default', *args, **kwargs): super(SFTPSensor, self).__init__(*args, **kwargs) self.path = path - self.hook = SFTPHook(sftp_conn_id=sftp_conn_id) + self.hook = SFTPHook(sftp_conn_id) def poke(self, context): logging.info('Poking for %s', self.path)
