fix: start containers in e2e tests before use

Author: Slach

e2e_test.go

@@ -506,10 +506,17 @@ func startClickHouseContainer(ctx context.Context) (testcontainers.Container, er
 		},
 		WaitingFor: wait.ForHTTP("/").WithPort("8123/tcp"),
 	}
-	return testcontainers.GenericContainer(ctx, testcontainers.GenericContainerRequest{
+	c, err := testcontainers.GenericContainer(ctx, testcontainers.GenericContainerRequest{
 		ContainerRequest: req,
 		Reuse:            false,
 	})
+	if err != nil {
+		return nil, err
+	}
+	if err := c.Start(ctx); err != nil {
+		return nil, err
+	}
+	return c, nil
 }
 
 func startMinioContainer(ctx context.Context) (testcontainers.Container, error) {
@@ -526,10 +533,17 @@ func startMinioContainer(ctx context.Context) (testcontainers.Container, error)
 		},
 		WaitingFor: wait.ForHTTP("/minio/health/ready").WithPort("9000/tcp").WithStartupTimeout(2 * time.Minute),
 	}
-	return testcontainers.GenericContainer(ctx, testcontainers.GenericContainerRequest{
+	c, err := testcontainers.GenericContainer(ctx, testcontainers.GenericContainerRequest{
 		ContainerRequest: req,
 		Reuse:            false,
 	})
+	if err != nil {
+		return nil, err
+	}
+	if err := c.Start(ctx); err != nil {
+		return nil, err
+	}
+	return c, nil
 }
 
 func startFakeGCSContainer(ctx context.Context) (testcontainers.Container, error) {
@@ -540,10 +554,17 @@ func startFakeGCSContainer(ctx context.Context) (testcontainers.Container, error
 		Cmd:          []string{"-scheme", "http"},
 		WaitingFor:   wait.ForHTTP("/").WithPort("4443/tcp"),
 	}
-	return testcontainers.GenericContainer(ctx, testcontainers.GenericContainerRequest{
+	c, err := testcontainers.GenericContainer(ctx, testcontainers.GenericContainerRequest{
 		ContainerRequest: req,
 		Reuse:            false,
 	})
+	if err != nil {
+		return nil, err
+	}
+	if err := c.Start(ctx); err != nil {
+		return nil, err
+	}
+	return c, nil
 }
 
 func startAzuriteContainer(ctx context.Context) (testcontainers.Container, error) {
@@ -554,10 +575,17 @@ func startAzuriteContainer(ctx context.Context) (testcontainers.Container, error
 		Cmd:          []string{"azurite-blob", "--blobHost", "0.0.0.0"},
 		WaitingFor:   wait.ForListeningPort("10000/tcp"),
 	}
-	return testcontainers.GenericContainer(ctx, testcontainers.GenericContainerRequest{
+	c, err := testcontainers.GenericContainer(ctx, testcontainers.GenericContainerRequest{
 		ContainerRequest: req,
 		Reuse:            false,
 	})
+	if err != nil {
+		return nil, err
+	}
+	if err := c.Start(ctx); err != nil {
+		return nil, err
+	}
+	return c, nil
 }
 
 func startFTPContainer(ctx context.Context) (testcontainers.Container, error) {
@@ -572,10 +600,17 @@ func startFTPContainer(ctx context.Context) (testcontainers.Container, error) {
 		},
 		WaitingFor: wait.ForListeningPort("21/tcp"),
 	}
-	return testcontainers.GenericContainer(ctx, testcontainers.GenericContainerRequest{
+	c, err := testcontainers.GenericContainer(ctx, testcontainers.GenericContainerRequest{
 		ContainerRequest: req,
 		Reuse:            false,
 	})
+	if err != nil {
+		return nil, err
+	}
+	if err := c.Start(ctx); err != nil {
+		return nil, err
+	}
+	return c, nil
 }
 
 func startSFTPContainer(ctx context.Context) (testcontainers.Container, error) {
@@ -588,10 +623,17 @@ func startSFTPContainer(ctx context.Context) (testcontainers.Container, error) {
 		},
 		WaitingFor: wait.ForListeningPort("22/tcp"),
 	}
-	return testcontainers.GenericContainer(ctx, testcontainers.GenericContainerRequest{
+	c, err := testcontainers.GenericContainer(ctx, testcontainers.GenericContainerRequest{
 		ContainerRequest: req,
 		Reuse:            false,
 	})
+	if err != nil {
+		return nil, err
+	}
+	if err := c.Start(ctx); err != nil {
+		return nil, err
+	}
+	return c, nil
 }
 
 func createTestTables(ctx context.Context, t *testing.T, container testcontainers.Container) error {