Flake8.

Nextdoor · Dec 30, 2019 · cab435a · cab435a
1 parent 4b9a04e
commit cab435a
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 3 deletions.
diff --git a/ndscheduler/corescheduler/core/base.py b/ndscheduler/corescheduler/core/base.py
@@ -2,6 +2,7 @@
 
 import json
 
+from ndscheduler import settings
 from apscheduler.schedulers import tornado as apscheduler_tornado
 
 from ndscheduler.corescheduler import constants
@@ -150,7 +151,7 @@ def add_scheduler_job(self, job_class_string, name, pub_args=None,
         return job_id
 
     def add_trigger_scheduler_job(self, job_class_string, name, pub_args, trigger,
-                          **kwargs):
+                                  **kwargs):
         """Add a job. Job infomation will be persistent in postgres.
 
         This is a NON-BLOCKING operation, as internally, apscheduler calls wakeup()

diff --git a/ndscheduler/corescheduler/datastore/base.py b/ndscheduler/corescheduler/datastore/base.py
@@ -129,7 +129,6 @@ def _build_execution(self, row):
                 'task_name': utils.get_job_name(job),
                 'pub_args': utils.get_job_args(job)}
 
-
             if isinstance(job.trigger, apscheduler.triggers.cron.CronTrigger):
                 return_json.update(utils.get_cron_strings(job))
                 return_json["trigger_type"] = "cron"

diff --git a/ndscheduler/corescheduler/datastore/providers/postgres.py b/ndscheduler/corescheduler/datastore/providers/postgres.py
@@ -1,5 +1,5 @@
 """Represents Postgres datastore."""
-
+import sys
 from ndscheduler.corescheduler.datastore import base