re-enable for test

Author: akuzni2

core/services/llo/observation/observation_context.go

@@ -339,14 +339,22 @@ func (oc *observationContext) run(ctx context.Context, streamID streams.StreamID
 	ex, isExecuting := oc.executions[p]
 	if isExecuting {
 		oc.executionsMu.Unlock()
+		// wait for it to finish
+		select {
+		case <-ex.done:
+			return ex.run, ex.trrs, ex.err
+		case <-ctx.Done():
+			return nil, nil, ctx.Err()
+		}
 		// Block unconditionally until the executing goroutine finishes.
 		// All waiters must receive the same (run, trrs, err) tuple to
 		// prevent partial cache writes for streams sharing a pipeline.
 		// This is safe because p.Run(ctx) respects context cancellation:
 		// when ctx expires, HTTP requests abort, the scheduler collects
 		// all error results, and p.Run returns promptly.
-		<-ex.done
-		return ex.run, ex.trrs, ex.err
+		// RE-ENABLE after test
+		// <-ex.done
+		// return ex.run, ex.trrs, ex.err
 	}
 
 	// execute here