* Replace the hard exception by a warning

The data pipeline is adding itself as a dependency which makes the
script fails.

* Fix check_all_metrics with non-matching dependencies tasks
This commit is contained in:
Boris Feld 2019-09-02 13:03:32 +02:00 коммит произвёл Marco
Родитель 724a6b4ec2
Коммит d3376b63db
1 изменённых файлов: 7 добавлений и 5 удалений

Просмотреть файл

@ -59,10 +59,10 @@ def get_model_name(queue, task_id: str):
model_name = route.split(".")[4] # model_name = "train_component"
return model_name[6:]
# Raise an exception if no matching route was found, this can happens when
# the current task has a dependency to a non-training task or if the route
# Show a warning if no matching route was found, this can happen when the
# current task has a dependency to a non-training task or if the route
# pattern changes.
raise Exception(f"No matching route found for task id {task_id}")
LOGGER.warning(f"No matching route found for task id {task_id}")
def get_model_names(task_id: str) -> List[str]:
@ -80,8 +80,10 @@ def get_model_names(task_id: str) -> List[str]:
)
model_name = get_model_name(queue, task_id)
LOGGER.info("Adding model %r to download list", model_name)
model_names.append(model_name)
if model_name:
LOGGER.info("Adding model %r to download list", model_name)
model_names.append(model_name)
return model_names