diff --git a/llo/plugin.go b/llo/plugin.go
index 426103f..19449ad 100644
--- a/llo/plugin.go
+++ b/llo/plugin.go
@@ -43,11 +43,14 @@ const (
 type DSOpts interface {
 	VerboseLogging() bool
 	SeqNr() uint64
+	OutCtx() ocr3types.OutcomeContext
+	ConfigDigest() ocr2types.ConfigDigest
 }
 
 type dsOpts struct {
 	verboseLogging bool
-	seqNr          uint64
+	outCtx         ocr3types.OutcomeContext
+	configDigest   ocr2types.ConfigDigest
 }
 
 func (o dsOpts) VerboseLogging() bool {
@@ -55,7 +58,15 @@ func (o dsOpts) VerboseLogging() bool {
 }
 
 func (o dsOpts) SeqNr() uint64 {
-	return o.seqNr
+	return o.outCtx.SeqNr
+}
+
+func (o dsOpts) OutCtx() ocr3types.OutcomeContext {
+	return o.outCtx
+}
+
+func (o dsOpts) ConfigDigest() ocr2types.ConfigDigest {
+	return o.configDigest
 }
 
 type DataSource interface {
diff --git a/llo/plugin_observation.go b/llo/plugin_observation.go
index 6c1f246..32843e0 100644
--- a/llo/plugin_observation.go
+++ b/llo/plugin_observation.go
@@ -137,7 +137,7 @@ func (p *Plugin) observation(ctx context.Context, outctx ocr3types.OutcomeContex
 			}
 		}
 
-		if err := p.DataSource.Observe(ctx, streamValues, dsOpts{p.Config.VerboseLogging, outctx.SeqNr}); err != nil {
+		if err := p.DataSource.Observe(ctx, streamValues, dsOpts{p.Config.VerboseLogging, outctx, p.ConfigDigest}); err != nil {
 			return nil, fmt.Errorf("DataSource.Observe error: %w", err)
 		}
 	}