From d2f57b3658ff22c6aed8700362d2cf11b907d650 Mon Sep 17 00:00:00 2001 From: Patrick Zhao Date: Tue, 23 Sep 2025 15:42:29 +0800 Subject: [PATCH] fix get docker host panic when dind replica is 0 Signed-off-by: Patrick Zhao --- .../workflowcontroller/jobcontroller/job_freestyle.go | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/pkg/microservice/aslan/core/common/service/workflowcontroller/jobcontroller/job_freestyle.go b/pkg/microservice/aslan/core/common/service/workflowcontroller/jobcontroller/job_freestyle.go index 3349fa7e7a..839fc222fe 100644 --- a/pkg/microservice/aslan/core/common/service/workflowcontroller/jobcontroller/job_freestyle.go +++ b/pkg/microservice/aslan/core/common/service/workflowcontroller/jobcontroller/job_freestyle.go @@ -150,8 +150,10 @@ func (c *FreestyleJobCtl) run(ctx context.Context) error { // decide which docker host to use. // TODO: do not use code in warpdrive moudule, should move to a public place - dockerhosts := dockerhost.NewDockerHosts(hubServerAddr, c.logger) - c.jobTaskSpec.Properties.DockerHost = dockerhosts.GetBestHost(dockerhost.ClusterID(c.jobTaskSpec.Properties.ClusterID), fmt.Sprintf("%v", c.workflowCtx.TaskID)) + if !c.jobTaskSpec.Properties.UseHostDockerDaemon { + dockerhosts := dockerhost.NewDockerHosts(hubServerAddr, c.logger) + c.jobTaskSpec.Properties.DockerHost = dockerhosts.GetBestHost(dockerhost.ClusterID(c.jobTaskSpec.Properties.ClusterID), fmt.Sprintf("%v", c.workflowCtx.TaskID)) + } // not local cluster var (