diff --git a/sdks/go/pkg/beam/runners/prism/internal/environments.go b/sdks/go/pkg/beam/runners/prism/internal/environments.go index 7d54cb366ffe..3a429920fb28 100644 --- a/sdks/go/pkg/beam/runners/prism/internal/environments.go +++ b/sdks/go/pkg/beam/runners/prism/internal/environments.go @@ -155,6 +155,7 @@ func dockerEnvironment(ctx context.Context, logger *slog.Logger, dp *pipepb.Dock }, &container.HostConfig{ NetworkMode: "host", Mounts: mounts, + AutoRemove: true, }, nil, nil, "") if err != nil { cli.Close()