ClearML/clearml
1
0
Fork 0
mirror of https://github.com/clearml/clearml synced 2025-02-12 07:35:08 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

Improve pipeline caching behaviour

Browse Source
This commit is contained in:
Alex Burlacu 2023-07-08 16:58:41 +03:00
parent 6dc2c8ca8c
commit 13f11a68be
1 changed files with 16 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
clearml/automation/job.py
View File

@ -416,7 +416,22 @@ class BaseJob(object):
# we need to ignore `requirements` section because ir might be changing from run to run # we need to ignore `requirements` section because ir might be changing from run to run
script.pop("requirements", None) script.pop("requirements", None)
hyper_params = task.get_parameters() if params_override is None else params_override hyper_params = deepcopy(task.get_parameters() if params_override is None else params_override)
hyper_params_to_change = {}
task_cache = {}
for key, value in hyper_params.items():
if key.startswith("kwargs_artifacts/"):
# noinspection PyBroadException
try:
# key format is <task_id>.<artifact_name>
task_id, artifact = value.split(".", 1)
task_ = task_cache.setdefault(task_id, Task.get_task(task_id))
# set the value of the hyper parameter to the hash of the artifact
# because the task ID might differ, but the artifact might be the same
hyper_params_to_change[key] = task_.artifacts[artifact].hash
except Exception:
pass
hyper_params.update(hyper_params_to_change)
configs = task.get_configuration_objects() if configurations_override is None else configurations_override configs = task.get_configuration_objects() if configurations_override is None else configurations_override
# currently we do not add the docker image to the hash (only args and setup script), # currently we do not add the docker image to the hash (only args and setup script),
# because default docker image will cause the step to change # because default docker image will cause the step to change