func TiStatusToVerb()

in pkg/source/apache-airflow/util.go [68:95]

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

func TiStatusToVerb(ti *model.AirflowTaskInstance) (enum.RevisionVerb, enum.RevisionState) {
	switch ti.Status() {
	case model.TASKINSTANCE_SCHEDULED:
		return enum.RevisionVerbComposerTaskInstanceScheduled, enum.RevisionStateComposerTiScheduled
	case model.TASKINSTANCE_QUEUED:
		return enum.RevisionVerbComposerTaskInstanceQueued, enum.RevisionStateComposerTiQueued
	case model.TASKINSTANCE_RUNNING:
		return enum.RevisionVerbComposerTaskInstanceRunning, enum.RevisionStateComposerTiRunning
	case model.TASKINSTANCE_SUCCESS:
		return enum.RevisionVerbComposerTaskInstanceSuccess, enum.RevisionStateComposerTiSuccess
	case model.TASKINSTANCE_FAILED:
		return enum.RevisionVerbComposerTaskInstanceFailed, enum.RevisionStateComposerTiFailed
	case model.TASKINSTANCE_DEFERRED:
		return enum.RevisionVerbComposerTaskInstanceDeferred, enum.RevisionStateComposerTiDeferred
	case model.TASKINSTANCE_UP_FOR_RETRY:
		return enum.RevisionVerbComposerTaskInstanceUpForRetry, enum.RevisionStateComposerTiUpForRetry
	case model.TASKINSTANCE_UP_FOR_RESCHEDULE:
		return enum.RevisionVerbComposerTaskInstanceUpForReschedule, enum.RevisionStateComposerTiUpForReschedule
	case model.TASKINSTANCE_REMOVED:
		return enum.RevisionVerbComposerTaskInstanceRemoved, enum.RevisionStateComposerTiRemoved
	case model.TASKINSTANCE_UPSTREAM_FAILED:
		return enum.RevisionVerbComposerTaskInstanceUpstreamFailed, enum.RevisionStateComposerTiUpstreamFailed
	case model.TASKINSTANCE_ZOMBIE:
		return enum.RevisionVerbComposerTaskInstanceZombie, enum.RevisionStateComposerTiZombie
	default:
		return enum.RevisionVerbComposerTaskInstanceUnimplemented, enum.RevisionStateConditionUnknown
	}
}