spacefreak/pyinotifyd
1
0
Fork 0
Code Issues Pull Requests Releases Activity

fix log error in scheduler

Browse Source
This commit is contained in:
Thomas Oettli
2020-11-05 15:15:30 +01:00
parent b2f0758931
commit 82c6d4a96d
1 changed files with 7 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
pyinotifyd/scheduler.py
View File

@@ -57,6 +57,9 @@ class _Task:
self.cancel() self.cancel()
self.start() self.start()
def task_id():
return self._task_id
class TaskScheduler: class TaskScheduler:
def __init__(self, task, files, dirs, delay=0, logname="sched"): def __init__(self, task, files, dirs, delay=0, logname="sched"):
@@ -97,9 +100,10 @@ class TaskScheduler:
if path in self._tasks: if path in self._tasks:
task = self._tasks[path] task = self._tasks[path]
task_id = task.task_id()
self._log.info( self._log.info(
f"received event {maskname} on '{path}', " f"received event {maskname} on '{path}', "
f"re-schedule task {task.task_id} (delay={self._delay}s)") f"re-schedule task {task_id} (delay={self._delay}s)")
task.restart() task.restart()
else: else:
task_id = str(uuid4()) task_id = str(uuid4())
@@ -119,9 +123,10 @@ class TaskScheduler:
maskname = event.maskname.split("|", 1)[0] maskname = event.maskname.split("|", 1)[0]
if path in self._tasks: if path in self._tasks:
task = self._tasks[path] task = self._tasks[path]
task_id = task.task_id()
self._log.info( self._log.info(
f"received event {maskname} on '{path}', " f"received event {maskname} on '{path}', "
f"cancel scheduled task {task.task_id}") f"cancel scheduled task {task_id}")
task.cancel() task.cancel()
del self._tasks[path] del self._tasks[path]