fix: ensure we say we failed if we fail to create a vol (#44)

Addresses a bug where tasks were not correctly marked as failed when a volume creation operation failed.

Author: w-h-a

internal/engine/clients/broker/rabbit/broker.go

@@ -118,6 +118,7 @@ func (b *rabbitBroker) Subscribe(ctx context.Context, callback func(ctx context.
 			}
 		}
 
+		// span
 		slog.ErrorContext(ctx, "subscriber failed to connect after max attempts", "queue", options.Queue, "maxAttempts", maxAttempts)
 	}()
 

internal/engine/services/worker/service.go

@@ -113,7 +113,22 @@ func (s *Service) runTask(ctx context.Context, t *task.Task) error {
 			runner.CreateVolumeWithName(volName),
 		}
 		if err := s.runner.CreateVolume(ctx, opts...); err != nil {
-			return err
+			finished := time.Now()
+			t.Error = err.Error()
+			t.State = task.Failed
+			t.FailedAt = &finished
+
+			failedBs, _ := json.Marshal(t)
+
+			failedOpts := []broker.PublishOption{
+				broker.PublishWithQueue(broker.FAILED),
+			}
+
+			if err := s.broker.Publish(ctx, failedBs, failedOpts...); err != nil {
+				return err
+			}
+
+			return nil
 		}
 		defer func(volName string) {
 			opts := []runner.DeleteVolumeOption{