downloadAllSC2Maps download all of the maps from the replays if the replays were not processed before.

FileProcessingPipeline is performing the whole data processing pipeline for a replay file.

MultiprocessingChunkPipeline is a single instance of processing that is meant to be spawned by the orchestrator in order to speed up the process of data extraction.

PipelineWrapper is an orchestrator that distributes work among available workers (threads).

Create new class, AnonymizerClient, that wraps the gRPC client (pb.NewAnonymizeServiceClient(conn) should happen once).

ReplayProcessingChannelContents is a struct that is used to pass data between the orchestrator and the workers in the pipeline.