Fix Flake8 errors

This commit is contained in:
OmarFarrag 2020-01-24 15:58:52 +02:00
parent 40e0a11aa8
commit 9e6d5573f1
2 changed files with 2 additions and 3 deletions

View File

@ -13,7 +13,6 @@ from collections import defaultdict
from email.utils import parsedate_tz, mktime_tz
from ftplib import FTP
from io import BytesIO
from six.moves.urllib.parse import urlparse
from urllib.parse import urlparse
from twisted.internet import defer, threads
@ -276,7 +275,7 @@ class FTPFilesStore(object):
self.password = u.password or self.FTP_PASSWORD
self.basedir = u.path.rstrip('/')
def persist_file(self, path, buf, info, meta=None, headers=None):
def persist_file(self, path, buf, info, meta=None, headers=None):
path = '%s/%s' % (self.basedir, path)
return threads.deferToThread(
ftp_store_file, path=path, file=buf,

View File

@ -67,7 +67,7 @@ def get_gcs_content_and_delete(bucket, path):
def get_ftp_content_and_delete(
path, host, port,username,
path, host, port, username,
password, use_active_mode=False):
from ftplib import FTP
ftp = FTP()