diff --git a/workflow_builder/argo_builder.go b/workflow_builder/argo_builder.go index 3893d76..03b9d38 100644 --- a/workflow_builder/argo_builder.go +++ b/workflow_builder/argo_builder.go @@ -179,7 +179,9 @@ func (b *ArgoBuilder) createArgoTemplates(namespace string, logger.Info().Msg(fmt.Sprint("Creating template for", template.Name)) isReparted, peerId := b.isProcessingReparted(*processing, id) template.CreateContainer(processing, b.Workflow.getDag()) + if isReparted { + logger.Debug().Msg("Reparted processing, on " + peerId) b.RemotePeers = append(b.RemotePeers, peerId) template.AddAdmiraltyAnnotations(peerId) }