feat: Open file when closed during processing chunks. · keboola/keboola-as-code@2e40f92

Run tests: internal/pkg/service/stream/storage/level/local/diskwriter/network/rpc/rpc_test.go#L118

undefined: encoding.NetworkOutput

Run tests: internal/pkg/service/stream/storage/level/local/encoding/pipeline_test.go#L44

not enough arguments in call to d.EncodingManager().OpenPipeline

Run tests: internal/pkg/service/stream/storage/level/local/encoding/pipeline_test.go#L84

not enough arguments in call to d.EncodingManager().OpenPipeline

Run tests: internal/pkg/service/stream/storage/level/local/encoding/pipeline_test.go#L107

not enough arguments in call to d.EncodingManager().OpenPipeline

Run tests: internal/pkg/service/stream/storage/level/local/encoding/pipeline_test.go#L563

not enough arguments in call to tc.Manager.OpenPipeline

Run tests: internal/pkg/service/stream/storage/level/local/encoding/encoder/factory_test.go#L45

not enough arguments in call to d.EncodingManager().OpenPipeline

Run tests: internal/pkg/service/stream/storage/level/local/encoding/encoder/factory_test.go#L60

not enough arguments in call to d.EncodingManager().OpenPipeline

Run tests: internal/pkg/service/stream/storage/level/local/diskwriter/network/rpc/rpc_test.go#L118

undefined: encoding.NetworkOutput

Run tests: internal/pkg/service/stream/storage/level/local/encoding/pipeline_test.go#L44

not enough arguments in call to d.EncodingManager().OpenPipeline

Run tests: internal/pkg/service/stream/storage/level/local/encoding/pipeline_test.go#L84

not enough arguments in call to d.EncodingManager().OpenPipeline

Provide feedback