From a1435afdf46cb797246708fbd91d71f7b017f5f6 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Mi=C5=82osz=20Sm=C3=B3=C5=82ka?= Date: Mon, 26 Aug 2024 16:17:40 +0200 Subject: [PATCH] . --- docker-compose.yml | 4 +--- pkg/googlecloud/pubsub_test.go | 5 ++--- 2 files changed, 3 insertions(+), 6 deletions(-) diff --git a/docker-compose.yml b/docker-compose.yml index a752001..b0e7adf 100644 --- 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 index 486836e..4a6fb51 100644 --- 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")