Function sendBlockJobStatusEventByJob

pkg/jobcontroller/jobcontroller.go:233–238

(ctx context.Context, job *waveobj.Job)

}

func sendBlockJobStatusEventByJob(ctx context.Context, job *waveobj.Job) {
	if job == nil || job.AttachedBlockId == "" {
		return
	}
	SendBlockJobStatusEvent(ctx, job.AttachedBlockId)
}

func connReconcileWorker() {
	defer func() {