fix py37 conflict due to async definition in scheduler
This commit is contained in:
+2
-2
@@ -525,7 +525,7 @@ class MetaScheduler(threading.Thread):
|
|||||||
self.have_heartbeat = True # set to False to kill
|
self.have_heartbeat = True # set to False to kill
|
||||||
self.empty_runs = 0
|
self.empty_runs = 0
|
||||||
|
|
||||||
def async(self, task):
|
def local_async(self, task):
|
||||||
"""Start the background process.
|
"""Start the background process.
|
||||||
|
|
||||||
Args:
|
Args:
|
||||||
@@ -913,7 +913,7 @@ class Scheduler(MetaScheduler):
|
|||||||
self.w_stats.empty_runs = 0
|
self.w_stats.empty_runs = 0
|
||||||
self.w_stats.status = RUNNING
|
self.w_stats.status = RUNNING
|
||||||
self.w_stats.total += 1
|
self.w_stats.total += 1
|
||||||
self.wrapped_report_task(task, self.async(task))
|
self.wrapped_report_task(task, self.local_async(task))
|
||||||
if not self.w_stats.status == DISABLED:
|
if not self.w_stats.status == DISABLED:
|
||||||
self.w_stats.status = ACTIVE
|
self.w_stats.status = ACTIVE
|
||||||
else:
|
else:
|
||||||
|
|||||||
Reference in New Issue
Block a user