diff options
Diffstat (limited to 'internal/processing/polls/expiry.go')
| -rw-r--r-- | internal/processing/polls/expiry.go | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/internal/processing/polls/expiry.go b/internal/processing/polls/expiry.go index 59d0f17fe..d02a05f0d 100644 --- a/internal/processing/polls/expiry.go +++ b/internal/processing/polls/expiry.go @@ -116,11 +116,11 @@ func (p *Processor) onExpiry(pollID string) func(context.Context, time.Time) { // Enqueue a status update operation to the client API worker, // this will asynchronously send an update with the Poll close time. - p.state.Workers.EnqueueClientAPI(ctx, messages.FromClientAPI{ + p.state.Workers.Client.Queue.Push(&messages.FromClientAPI{ APActivityType: ap.ActivityUpdate, APObjectType: ap.ObjectNote, GTSModel: status, - OriginAccount: status.Account, + Origin: status.Account, }) } } |