From 8c689fd117a972b590ae91b214c639f552ddfdbc Mon Sep 17 00:00:00 2001
From: jrybicki-jsc <j.rybicki@fz-juelich.de>
Date: Fri, 8 Apr 2022 18:07:32 +0200
Subject: [PATCH] spelling
---
dags/image_transfer.py | 10 ----------
1 file changed, 10 deletions(-)
diff --git a/dags/image_transfer.py b/dags/image_transfer.py
index 08ced7e..02e764f 100644
--- a/dags/image_transfer.py
+++ b/dags/image_transfer.py
@@ -1,11 +1,9 @@
import os
-import shutil
import requests
from airflow.decorators import dag, task
from airflow.utils.dates import days_ago
from airflow.operators.python import PythonOperator
-import paramiko
from decors import setup, get_connection, remove
@@ -13,13 +11,6 @@ default_args = {
'owner': 'airflow',
}
-class FastTransport(paramiko.Transport):
-
- def __init__(self, sock):
- super(FastTransport, self).__init__(sock)
- self.window_size = 2147483647
- self.packetizer.REKEY_BYTES = pow(2, 40)
- self.packetizer.REKEY_PACKETS = pow(2, 40)
@dag(default_args=default_args, schedule_interval=None, start_date=days_ago(2), tags=['example'])
@@ -36,7 +27,6 @@ def transfer_image():
ssh_hook = get_connection(conn_id=connection_id, **kwargs)
with ssh_hook.get_conn() as ssh_client:
- ssh_client.s
sftp_client = ssh_client.open_sftp()
ssh_client.exec_command(command=f"mkdir -p {target}")
--
GitLab