Function GetBlockJobStatus

pkg/jobcontroller/jobcontroller.go:171–218

(ctx context.Context, blockId string)

}

func GetBlockJobStatus(ctx context.Context, blockId string) (*wshrpc.BlockJobStatusData, error) {
	block, err := wstore.DBGet[*waveobj.Block](ctx, blockId)
	if err != nil {
		return nil, fmt.Errorf("failed to get block: %w", err)
	}
	if block == nil {
		return nil, fmt.Errorf("block not found: %s", blockId)
	}

	data := &wshrpc.BlockJobStatusData{
		BlockId:   blockId,
		VersionTs: blockJobStatusVersion.GetVersionTs(),
	}

	if block.JobId == "" {
		return data, nil
	}

	job, err := wstore.DBGet[*waveobj.Job](ctx, block.JobId)
	if err != nil {
		return nil, fmt.Errorf("failed to get job: %w", err)
	}
	if job == nil {
		return data, nil
	}

	data.JobId = job.OID
	data.DoneReason = job.JobManagerDoneReason
	data.StartupError = job.JobManagerStartupError
	data.CmdExitTs = job.CmdExitTs
	data.CmdExitCode = job.CmdExitCode
	data.CmdExitSignal = job.CmdExitSignal

	if job.JobManagerStatus == JobManagerStatus_Init {
		data.Status = "init"
	} else if job.JobManagerStatus == JobManagerStatus_Done {
		data.Status = "done"
	} else if job.JobManagerStatus == JobManagerStatus_Running {
		connStatus := GetJobConnStatus(job.OID)
		if connStatus == JobConnStatus_Connected {
			data.Status = "connected"
		} else {
			data.Status = "disconnected"
		}
	}

	return data, nil
}

func SendBlockJobStatusEvent(ctx context.Context, blockId string) {
	data, err := GetBlockJobStatus(ctx, blockId)