From a31565ec6b8e6b35e2bdf88a1db710588a4653c3 Mon Sep 17 00:00:00 2001 From: mski_iksm <34547057+mski-iksm@users.noreply.github.com> Date: Tue, 21 May 2024 19:37:24 +0900 Subject: [PATCH] random priority (#376) --- gokart/task.py | 5 +++++ 1 file changed, 5 insertions(+) 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.'