File tree Expand file tree Collapse file tree 1 file changed +6
-2
lines changed
enterprise/coderd/prebuilds Expand file tree Collapse file tree 1 file changed +6
-2
lines changed Original file line number Diff line number Diff line change @@ -103,8 +103,12 @@ func (c *StoreReconciler) Run(ctx context.Context) {
103
103
c .running .Store (true )
104
104
105
105
// Publish provisioning jobs outside of database transactions.
106
- // PGPubsub tries to acquire a new connection on Publish. A connection is held while a database transaction is active,
107
- // so we can exhaust available connections.
106
+ // A connection is held while a database transaction is active; PGPubsub also tries to acquire a new connection on
107
+ // Publish, so we can exhaust available connections.
108
+ //
109
+ // A single worker dequeues from the channel, which should be sufficient.
110
+ // If any messages are missed due to congestion or errors, provisionerdserver has a backup polling mechanism which
111
+ // will periodically pick up any queued jobs (see poll(time.Duration) in coderd/provisionerdserver/acquirer.go).
108
112
go func () {
109
113
for {
110
114
select {
You can’t perform that action at this time.
0 commit comments