fix TaskState class
This commit is contained in:
@@ -25,7 +25,6 @@ import os
|
|||||||
import re
|
import re
|
||||||
import shutil
|
import shutil
|
||||||
|
|
||||||
from dataclasses import dataclass
|
|
||||||
from inspect import iscoroutinefunction
|
from inspect import iscoroutinefunction
|
||||||
from shlex import quote as shell_quote
|
from shlex import quote as shell_quote
|
||||||
from uuid import uuid4
|
from uuid import uuid4
|
||||||
@@ -46,11 +45,11 @@ class SchedulerLogger(logging.LoggerAdapter):
|
|||||||
|
|
||||||
class TaskScheduler:
|
class TaskScheduler:
|
||||||
|
|
||||||
@dataclass
|
|
||||||
class TaskState:
|
class TaskState:
|
||||||
id: str = str(uuid4())
|
def __init__(self, id=None, task=None, cancelable=True):
|
||||||
task: asyncio.Task = None
|
self.id = id or str(uuid4())
|
||||||
cancelable: bool = True
|
self.task = task
|
||||||
|
self.cancelable = cancelable
|
||||||
|
|
||||||
def __init__(self, job, files=True, dirs=False, delay=0, logname="sched",
|
def __init__(self, job, files=True, dirs=False, delay=0, logname="sched",
|
||||||
loop=None):
|
loop=None):
|
||||||
|
|||||||
Reference in New Issue
Block a user