We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent aeb4b80 commit e67408dCopy full SHA for e67408d
scheduler/management/commands/import.py
@@ -21,14 +21,13 @@ def job_model_str(model_str: str) -> str:
21
22
def get_task_type(model_str: str) -> TaskType:
23
model_str = job_model_str(model_str)
24
- if model_str not in MODEL_NAMES:
25
- raise ValueError(f"Invalid model {model_str}")
26
if model_str == "CronTask":
27
return TaskType.CRON
28
elif model_str == "RepeatableTask":
29
return TaskType.REPEATABLE
30
- elif model_str == "ScheduledTask":
+ elif model_str in {"ScheduledTask", "OnceTask"}:
31
return TaskType.ONCE
+ raise ValueError(f"Invalid model {model_str}")
32
33
34
def create_task_from_dict(task_dict: Dict[str, Any], update):
0 commit comments