Function SendBlockJobStatusEvent

pkg/jobcontroller/jobcontroller.go:220–231

(ctx context.Context, blockId string)

}

func SendBlockJobStatusEvent(ctx context.Context, blockId string) {
	data, err := GetBlockJobStatus(ctx, blockId)
	if err != nil {
		log.Printf("[block:%s] error getting block job status: %v", blockId, err)
		return
	}
	wps.Broker.Publish(wps.WaveEvent{
		Event:  wps.Event_BlockJobStatus,
		Scopes: []string{fmt.Sprintf("block:%s", blockId)},
		Data:   data,
	})
}

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