func StringToTiState()

in pkg/source/apache-airflow/util.go [38:65]

• 28 lines of code
• 12 McCabe index (conditional complexity)

func StringToTiState(stateStr string) (model.Tistate, error) {
	switch stateStr {
	case "scheduled":
		return model.TASKINSTANCE_SCHEDULED, nil
	case "queued":
		return model.TASKINSTANCE_QUEUED, nil
	case "running":
		return model.TASKINSTANCE_RUNNING, nil
	case "success":
		return model.TASKINSTANCE_SUCCESS, nil
	case "failed":
		return model.TASKINSTANCE_FAILED, nil
	case "deferred":
		return model.TASKINSTANCE_DEFERRED, nil
	case "up_for_retry":
		return model.TASKINSTANCE_UP_FOR_RETRY, nil
	case "up_for_reschedule":
		return model.TASKINSTANCE_UP_FOR_RESCHEDULE, nil
	case "removed":
		return model.TASKINSTANCE_REMOVED, nil
	case "upstream_failed":
		return model.TASKINSTANCE_UPSTREAM_FAILED, nil
	case "zombie":
		return model.TASKINSTANCE_ZOMBIE, nil
	default:
		return "", fmt.Errorf("unknown Airflow task state: %s", stateStr)
	}
}