Merge pull request #2541 from keboola/mvasko/fix-node-test-shutdown-log-assertion

fix(test): remove stale etcd connection log assertions

Author: Matovidlo

internal/pkg/service/common/task/node_test.go

@@ -940,9 +940,6 @@ task/123/my-receiver/my-export/some.task/%s
 {"level":"info","message":"closing etcd session: context canceled","component":"task.etcd.session","node":"node1"}
 {"level":"info","message":"closed etcd session","component":"task.etcd.session","node":"node1"}
 {"level":"info","message":"shutdown done","component":"task","node":"node1"}
-{"level":"info","message":"closing etcd connection","component":"etcd.client"}
-{"level":"info","message":"closed etcd connection","component":"etcd.client"}
-{"level":"info","message":"exited"}
 `, logs.String())
 }
 

internal/pkg/service/stream/storage/level/local/diskwriter/network/transport/protocol_kcp_test.go

@@ -1,6 +1,7 @@
 package transport_test
 
 import (
+	"runtime"
 	"testing"
 
 	"github.com/keboola/keboola-as-code/internal/pkg/service/stream/storage/level/local/diskwriter/network"
@@ -15,5 +16,8 @@ func TestTransport_SmallData_KCP(t *testing.T) {
 
 func TestTransportBiggerData_KCP(t *testing.T) {
 	t.Parallel()
+	if runtime.GOOS == "windows" {
+		t.Skip("skipped on Windows")
+	}
 	testTransportBiggerData(t, func(cfg network.Config) transport.Protocol { return kcp.New(cfg) })
 }