diff --git a/internal/connectors/engine/workflow/reset_connector.go b/internal/connectors/engine/workflow/reset_connector.go
index cd34c9ab..8916c534 100644
--- a/internal/connectors/engine/workflow/reset_connector.go
+++ b/internal/connectors/engine/workflow/reset_connector.go
@@ -126,7 +126,7 @@ func (w Workflow) resetConnector(
 		),
 		RunInstallConnector,
 		InstallConnector{
-			ConnectorID: resetConnector.ConnectorID,
+			ConnectorID: newConnector.ID,
 			Config:      config,
 		},
 	).Get(ctx, nil); err != nil {
diff --git a/internal/connectors/engine/workflow/send_events.go b/internal/connectors/engine/workflow/send_events.go
index 592ac353..12cd4cb1 100644
--- a/internal/connectors/engine/workflow/send_events.go
+++ b/internal/connectors/engine/workflow/send_events.go
@@ -102,7 +102,7 @@ func (w Workflow) runSendEvents(
 		err := sendEvent(
 			ctx,
 			fmt.Sprintf("%s-%s", sendEvents.ConnectorReset.String(), now.Format(time.RFC3339Nano)),
-			sendEvents.ConnectorReset,
+			nil,
 			func(ctx workflow.Context) error {
 				return activities.EventsSendConnectorReset(
 					infiniteRetryContext(ctx),