This is an automated email from the ASF dual-hosted git repository.
sruehl pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/plc4x.git
The following commit(s) were added to refs/heads/develop by this push:
new c9e08520a7 refactor(plc4go/spi): clean up interfaces of WorkerPool
c9e08520a7 is described below
commit c9e08520a7cddecf16f2e6cc76da1009bbdbf453
Author: Sebastian Rühl <[email protected]>
AuthorDate: Tue Mar 21 11:51:19 2023 +0100
refactor(plc4go/spi): clean up interfaces of WorkerPool
---
plc4go/internal/cbus/Reader.go | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/plc4go/internal/cbus/Reader.go b/plc4go/internal/cbus/Reader.go
index de1be62cee..d5dc18b70e 100644
--- a/plc4go/internal/cbus/Reader.go
+++ b/plc4go/internal/cbus/Reader.go
@@ -399,7 +399,7 @@ func (m *Reader) Read(ctx context.Context, readRequest
apiModel.PlcReadRequest)
_ =
transaction.FailRequest(errors.Errorf("timeout after %ss", time.Second*1))
}
})
- if err := transaction.AwaitCompletion(); err != nil {
+ if err := transaction.AwaitCompletion(ctx); err != nil {
log.Warn().Err(err).Msg("Error while awaiting
completion")
}
}