diff --git a/gokart/task.py b/gokart/task.py index 9f30d0b8..7996c9c1 100644 --- a/gokart/task.py +++ b/gokart/task.py @@ -1,6 +1,7 @@ import hashlib import inspect import os +import random import types from importlib import import_module from logging import getLogger @@ -86,6 +87,10 @@ class TaskOnKart(luigi.Task): ) should_lock_run: bool = ExplicitBoolParameter(default=False, significant=False, description='Whether to use redis lock or not at task run.') + @property + def priority(self): + return random.Random().random() # seed is fixed, so we need to use random.Random().random() instead f random.random() + def __init__(self, *args, **kwargs): self._add_configuration(kwargs, 'TaskOnKart') # 'This parameter is dumped into "workspace_directory/log/task_log/" when this task finishes with success.'