From aa41ae2ba241481f776ba5a49ebfd62f7cc4b9f5 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Sybren=20A=2E=20St=C3=BCvel?= Date: Mon, 14 Feb 2022 18:01:48 +0100 Subject: [PATCH] Worker: remove fixed error returns from listener --- internal/worker/listener.go | 11 +++++------ 1 file changed, 5 insertions(+), 6 deletions(-) diff --git a/internal/worker/listener.go b/internal/worker/listener.go index e99b80ae..b6abddb0 100644 --- a/internal/worker/listener.go +++ b/internal/worker/listener.go @@ -2,7 +2,6 @@ package worker import ( "context" - "errors" "sync" "time" @@ -73,25 +72,25 @@ func (l *Listener) Wait() { // TaskStarted tells the Manager that task execution has started. func (l *Listener) TaskStarted(taskID TaskID) error { - return errors.New("not implemented") + return nil } // TaskFailed tells the Manager the task failed for some reason. func (l *Listener) TaskFailed(taskID TaskID, reason string) error { - return errors.New("not implemented") + return nil } // TaskCompleted tells the Manager the task has been completed. func (l *Listener) TaskCompleted(taskID TaskID) error { - return errors.New("not implemented") + return nil } // LogProduced sends any logging to whatever service for storing logging. func (l *Listener) LogProduced(taskID TaskID, logLines ...string) error { - return errors.New("not implemented") + return nil } // OutputProduced tells the Manager there has been some output (most commonly a rendered frame or video). func (l *Listener) OutputProduced(taskID TaskID, outputLocation string) error { - return errors.New("not implemented") + return nil }