Skip to content

Commit b549ac7

Browse files
committed
remove volume bind to local dir
1 parent 9e5d2cb commit b549ac7

File tree

3 files changed

+4
-14
lines changed

3 files changed

+4
-14
lines changed

core/src/main/java/com/flowci/core/agent/domain/LocalUnixAgentHost.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -28,5 +28,6 @@ public class LocalUnixAgentHost extends AgentHost {
2828

2929
public LocalUnixAgentHost() {
3030
this.setType(AgentHost.Type.LocalUnixSocket);
31+
this.setMaxSize(2);
3132
}
3233
}

core/src/main/java/com/flowci/core/agent/service/AgentHostServiceImpl.java

Lines changed: 1 addition & 13 deletions
Original file line numberDiff line numberDiff line change
@@ -355,18 +355,8 @@ public void onContextReady(ContextRefreshedEvent event) {
355355

356356
@EventListener
357357
public void onNoIdleAgent(NoIdleAgentEvent event) {
358-
if (!appProperties.isAutoLocalAgentHost()) {
359-
return;
360-
}
361-
362358
Set<String> agentTags = event.getSelector().getLabel();
363-
364-
List<AgentHost> hosts;
365-
if (agentTags.isEmpty()) {
366-
hosts = list();
367-
} else {
368-
hosts = agentHostDao.findAllByTagsIn(agentTags);
369-
}
359+
List<AgentHost> hosts = agentTags.isEmpty() ? list() : agentHostDao.findAllByTagsIn(agentTags);
370360

371361
if (hosts.isEmpty()) {
372362
log.warn("Unable to find matched agent host for job {}", event.getJobId());
@@ -397,9 +387,7 @@ private DockerStartOption buildStartOption(Agent agent) {
397387
option.addEnv(AGENT_VOLUMES, System.getenv(AGENT_VOLUMES));
398388
option.addEnv(AGENT_WORKSPACE, DefaultWorkspace);
399389

400-
option.addBind(String.format("${HOME}/.agent-%s", agent.getName()), DefaultWorkspace);
401390
option.addBind(DockerSock, DockerSock);
402-
403391
return option;
404392
}
405393

core/src/main/java/com/flowci/core/job/event/NoIdleAgentEvent.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -16,12 +16,13 @@
1616

1717
package com.flowci.core.job.event;
1818

19+
import com.flowci.core.common.event.AsyncEvent;
1920
import com.flowci.tree.Selector;
2021
import lombok.Getter;
2122
import org.springframework.context.ApplicationEvent;
2223

2324
@Getter
24-
public class NoIdleAgentEvent extends ApplicationEvent {
25+
public class NoIdleAgentEvent extends ApplicationEvent implements AsyncEvent {
2526

2627
private final String jobId;
2728

0 commit comments

Comments
 (0)