diff options
| author | Till Faelligen <2353100+S7evinK@users.noreply.github.com> | 2022-10-28 08:17:40 +0200 |
|---|---|---|
| committer | Till Faelligen <2353100+S7evinK@users.noreply.github.com> | 2022-10-28 08:17:40 +0200 |
| commit | f6035822e75ad000869a0e01eff35941280f0250 (patch) | |
| tree | eae0b2c137b69bd3bddca74cb2624addedfc4060 /syncapi/streams | |
| parent | a2706e6498287a5b052ef47413175bf7551b36b1 (diff) | |
Simplify error checking and check the correct error
Diffstat (limited to 'syncapi/streams')
| -rw-r--r-- | syncapi/streams/stream_pdu.go | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/syncapi/streams/stream_pdu.go b/syncapi/streams/stream_pdu.go index 90cf8ce5..87f7a064 100644 --- a/syncapi/streams/stream_pdu.go +++ b/syncapi/streams/stream_pdu.go @@ -101,7 +101,7 @@ func (p *PDUStreamProvider) CompleteSync( ) if jerr != nil { req.Log.WithError(jerr).Error("p.getJoinResponseForCompleteSync failed") - if err == context.DeadlineExceeded || err == context.Canceled || err == sql.ErrTxDone { + if ctxErr := req.Context.Err(); ctxErr != nil || jerr == sql.ErrTxDone { return from } continue |