from doit import task_params
from doit.exceptions import TaskFailed
import subprocess
@task_params([{"name": "param_b", "default": "", "type": str, "long": "param_b"}])
def task_b(param_b: str):
def _execute():
if not param_b:
return TaskFailed("param_b must be defined")
ret = subprocess.call(["echo", param_b])
if ret == 0:
return True
return ret
return {
"actions": [_execute]
}
@task_params([{"name": "param_a", "default": "", "type": str, "long": "param_a"}])
def task_a(param_a: str):
return {
"actions": [f"echo {param_a}"],
"task_dep": ["b"]
}