diff --git a/core/services/pipeline/task.vrfv2.go b/core/services/pipeline/task.vrfv2.go
index a871e543496..2c2c85eaedf 100644
--- a/core/services/pipeline/task.vrfv2.go
+++ b/core/services/pipeline/task.vrfv2.go
@@ -39,7 +39,7 @@ func (t *VRFTaskV2) Type() TaskType {
 	return TaskTypeVRFV2
 }
 
-func (t *VRFTaskV2) Run(_ context.Context, _ logger.Logger, vars Vars, inputs []Result) (result Result, runInfo RunInfo) {
+func (t *VRFTaskV2) Run(_ context.Context, lggr logger.Logger, vars Vars, inputs []Result) (result Result, runInfo RunInfo) {
 	if len(inputs) != 1 {
 		return Result{Error: ErrWrongInputCardinality}, runInfo
 	}
@@ -134,7 +134,8 @@ func (t *VRFTaskV2) Run(_ context.Context, _ logger.Logger, vars Vars, inputs []
 		return Result{Error: err}, runInfo
 	}
 	results := make(map[string]interface{})
-	results["output"] = hexutil.Encode(b)
+	output := hexutil.Encode(b)
+	results["output"] = output
 	// RequestID needs to be a [32]byte for EvmTxMeta.
 	results["requestID"] = hexutil.Encode(requestId.Bytes())
 
@@ -142,5 +143,7 @@ func (t *VRFTaskV2) Run(_ context.Context, _ logger.Logger, vars Vars, inputs []
 	results["proof"] = onChainProof
 	results["requestCommitment"] = rc
 
+	lggr.Debugw("Completed VRF V2 task run", "reqID", requestId.String(), "output", output)
+
 	return Result{Value: results}, runInfo
 }
diff --git a/core/services/pipeline/task.vrfv2plus.go b/core/services/pipeline/task.vrfv2plus.go
index a596bfa3092..c029af68cbe 100644
--- a/core/services/pipeline/task.vrfv2plus.go
+++ b/core/services/pipeline/task.vrfv2plus.go
@@ -42,7 +42,7 @@ func (t *VRFTaskV2Plus) Type() TaskType {
 	return TaskTypeVRFV2Plus
 }
 
-func (t *VRFTaskV2Plus) Run(_ context.Context, _ logger.Logger, vars Vars, inputs []Result) (result Result, runInfo RunInfo) {
+func (t *VRFTaskV2Plus) Run(_ context.Context, lggr logger.Logger, vars Vars, inputs []Result) (result Result, runInfo RunInfo) {
 	if len(inputs) != 1 {
 		return Result{Error: ErrWrongInputCardinality}, runInfo
 	}
@@ -142,7 +142,8 @@ func (t *VRFTaskV2Plus) Run(_ context.Context, _ logger.Logger, vars Vars, input
 		return Result{Error: err}, runInfo
 	}
 	results := make(map[string]interface{})
-	results["output"] = hexutil.Encode(b)
+	output := hexutil.Encode(b)
+	results["output"] = output
 	// RequestID needs to be a [32]byte for EvmTxMeta.
 	results["requestID"] = hexutil.Encode(requestId.Bytes())
 
@@ -150,5 +151,7 @@ func (t *VRFTaskV2Plus) Run(_ context.Context, _ logger.Logger, vars Vars, input
 	results["proof"] = onChainProof
 	results["requestCommitment"] = rc
 
+	lggr.Debugw("Completed VRF V2 task run", "reqID", requestId.String(), "output", output)
+
 	return Result{Value: results}, runInfo
 }