Use Run method

distribworks · May 5, 2020 · fa95821 · fa95821
1 parent 6b4ded5
commit fa95821
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/dkron/grpc.go b/dkron/grpc.go
@@ -215,7 +215,7 @@ func (grpcs *GRPCServer) ExecutionDone(ctx context.Context, execDoneReq *proto.E
 			"execution": execution,
 		}).Debug("grpc: Retrying execution")
 
-		if _, err := grpcs.agent.RunQuery(job.Name, execution); err != nil {
+		if _, err := grpcs.agent.Run(job.Name, execution); err != nil {
 			return nil, err
 		}
 		return &proto.ExecutionDoneResponse{