fast-pizza-24629
09/12/2023, 2:41 PM2191 pods, all is good, it runs nicely, but in the join step, we get an error in init
exec /bin/argoexec: argument list too long
The same flow runs with no issues in K8s (without argo). It seems to be an issue related to the max size of env variable ARGO_TEMPLATE in the init container that has a limit of 128kb (source), have any of you encountered this issue before?limited-tomato-18674
09/12/2023, 5:23 PMfast-pizza-24629
09/13/2023, 8:30 AMancient-application-36103
09/13/2023, 3:49 PMfast-pizza-24629
09/14/2023, 12:57 PMinit container of our Join step. I am not really sure how to address this issue. Is there a way to make the Join step init container not to have the list of steps to join repeated 3 times? the variable ARGO_TEMPLATE in the container looks like this (attached, too large to paste it here). Our join step looks like this:
@kubernetes(disk=KUBERNETES_DISK)
@step
def join(self, inputs):
from lab.projects.sport_basic.detection_model.data_generation.helpers import create_subset_json create_dataset_metadata,
inputs = [input for input in inputs if not input.process_failure]
self.merge_artifacts(inputs, include=["config"])
self.combined_data = [(input.data_splits, input.data) for input in inputs]
create_subset_json(config=self.config, combined_data=self.combined_data)
create_dataset_metadata(self.config, flow=current.flow_name)
self.next(self.end)
Where the step before is a foreach of +2000... Thank you in advance for the help 🙏ancient-application-36103
09/14/2023, 2:59 PMbulky-afternoon-92433
09/14/2023, 3:19 PM