last fixes

formancehq · Jan 2, 2025 · d47c92b · d47c92b
1 parent b296d0b
commit d47c92b
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git 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
@@ -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),