This package deals with the communication with AWS-Batch and adopting its APIs to the flyte-plugin model.

Assembles a single outputs.pb that contain all the outputs of the subtasks and write them to the final OutputWriter.

When an AWS Batch array job kicks off, it is given the index of the array job in an environment variable.

ConstructStaticInputReaders constructs input readers that comply with the io.InputReader interface but have their inputs already populated.

DetermineDiscoverability checks if there are any previously cached tasks.

Represents an indexed work queue that aggregates outputs of sub tasks.

StaticInputReader complies with the io.InputReader interface but has the input already populated.