.

ThreeDotsLabs · Aug 26, 2024 · a1435af · a1435af
1 parent 3af8b51
commit a1435af
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 6 deletions.
diff --git a/docker-compose.yml b/docker-compose.yml
@@ -1,10 +1,8 @@
 # for Watermill development purposes.
 # For Watermill based application docker please check https://watermill.io/docs/getting-started/
-
-version: '3'
 services:
  googlecloud:
- image: google/cloud-sdk:360.0.0
+ image: google/cloud-sdk:489.0.0
  entrypoint: gcloud --quiet beta emulators pubsub start --host-port=0.0.0.0:8085 --verbosity=debug --log-http
  ports:
  - 8085:8085

diff --git a/pkg/googlecloud/pubsub_test.go b/pkg/googlecloud/pubsub_test.go
@@ -280,8 +280,6 @@ func produceMessages(t *testing.T, topic string, howMany int) {
 }
 
 func TestPublishOrdering(t *testing.T) {
- t.Skip("to investigate")
-
  pub, sub := newPubSub(
  t,
  true,
@@ -330,7 +328,8 @@ func TestPublishOrdering(t *testing.T) {
  for i := 0; i < len(toPublish); i++ {
  select {
  case msg := <-messages:
- received[msg.Metadata["ordering"]] = append(received[msg.Metadata["ordering"]], msg.UUID)
+ key := msg.Metadata["ordering"]
+ received[key] = append(received[key], msg.UUID)
  msg.Ack()
  case <-time.After(5 * time.Second):
  t.Fatal("timeout")