GetMPIPhaseInfo

No overview available.

def GetMPIPhaseInfo(
    currentCondition: kubeflowv1.JobCondition,
    occurredAt: time.Time,
    taskPhaseInfo: pluginsCore.TaskInfo
) - > pluginsCore.PhaseInfo, error

Returns the phase of an MPI job based on its current condition. This function is used to translate Kubernetes job conditions into a standardized phase representation for Flyte.

Parameters

Name	Type	Description
currentCondition	kubeflowv1.JobCondition	The current condition of the MPI job, indicating its state in the Kubernetes cluster.
occurredAt	time.Time	The timestamp when the current job condition occurred, used for queued phase information.
taskPhaseInfo	pluginsCore.TaskInfo	Additional information about the task associated with the MPI job, which is included in the returned phase.

Returns

Type	Description
pluginsCore.PhaseInfo, error	The determined phase information for the MPI job and an error if the phase could not be determined.