Make debounced functions respect the paused_at field (#1351)

inngest · May 13, 2024 · 3af47ce · 3af47ce
1 parent bda3400
commit 3af47ce
Show file tree

Hide file tree

Showing 2 changed files with 15 additions and 13 deletions.
diff --git a/pkg/execution/executor/executor.go b/pkg/execution/executor/executor.go
@@ -272,13 +272,14 @@ func (e *executor) AddLifecycleListener(l execution.LifecycleListener) {
 func (e *executor) Schedule(ctx context.Context, req execution.ScheduleRequest) (*state.Identifier, error) {
 	if req.Function.Debounce != nil && !req.PreventDebounce {
 		err := e.debouncer.Debounce(ctx, debounce.DebounceItem{
-			AccountID:       req.AccountID,
-			WorkspaceID:     req.WorkspaceID,
-			AppID:           req.AppID,
-			FunctionID:      req.Function.ID,
-			FunctionVersion: req.Function.FunctionVersion,
-			EventID:         req.Events[0].GetInternalID(),
-			Event:           req.Events[0].GetEvent(),
+			AccountID:        req.AccountID,
+			WorkspaceID:      req.WorkspaceID,
+			AppID:            req.AppID,
+			FunctionID:       req.Function.ID,
+			FunctionVersion:  req.Function.FunctionVersion,
+			EventID:          req.Events[0].GetInternalID(),
+			Event:            req.Events[0].GetEvent(),
+			FunctionPausedAt: req.FunctionPausedAt,
 		}, req.Function)
 		if err != nil {
 			return nil, err

diff --git a/pkg/execution/executor/service.go b/pkg/execution/executor/service.go
@@ -364,12 +364,13 @@ func (s *svc) handleDebounce(ctx context.Context, item queue.Item) error {
 			defer span.End()
 
 			_, err = s.exec.Schedule(ctx, execution.ScheduleRequest{
-				Function:        f,
-				AccountID:       di.AccountID,
-				WorkspaceID:     di.WorkspaceID,
-				AppID:           di.AppID,
-				Events:          []event.TrackedEvent{di},
-				PreventDebounce: true,
+				Function:         f,
+				AccountID:        di.AccountID,
+				WorkspaceID:      di.WorkspaceID,
+				AppID:            di.AppID,
+				Events:           []event.TrackedEvent{di},
+				PreventDebounce:  true,
+				FunctionPausedAt: di.FunctionPausedAt,
 			})
 			if err != nil {
 				return err