[Bug] [api-server] Worker group cannot be assigned to a project

[k1z]

Search before asking

• I had searched in the issues and found no similar issues.

What happened

When I assigned a workgroup to a project, it prompted me: Failed to assign a workgroup to the project

api-server log

2025-10-27 15:04:22.235 ERROR [qtp767266208-12279] o.a.d.a.s.i.ProjectWorkerGroupRelationServiceImpl:[143] - Failed to delete worker groups [[worker-240.118]] for the project [运维].
2025-10-27 15:04:22.235 ERROR [qtp767266208-12279] o.a.d.a.e.ApiExceptionHandler:[40] - org.apache.dolphinscheduler.api.controller.ProjectWorkerGroupController#assignWorkerGroups[3 args] Meet a ServiceException: 给项目分配工作组失败

but, if i create a new project , can assign

2025-10-27 15:05:28.525 INFO [qtp767266208-12436] o.a.d.a.s.i.ProjectServiceImpl:[134] - Project is created and id is :7
2025-10-27 15:05:32.122 INFO [qtp767266208-12308] o.a.d.a.s.i.ProjectWorkerGroupRelationServiceImpl:[141] - Success to delete worker groups [[default, worker-240.118, Linux-prod, worker-10.10.243.142]] for the project [测试] .
2025-10-27 15:05:32.124 INFO [qtp767266208-12308] o.a.d.a.s.i.ProjectWorkerGroupRelationServiceImpl:[155] - Success to add worker group [default] for the project [测试] .
2025-10-27 15:05:32.124 INFO [qtp767266208-12308] o.a.d.a.s.i.ProjectWorkerGroupRelationServiceImpl:[155] - Success to add worker group [worker-240.118] for the project [测试] .
2025-10-27 15:05:32.125 INFO [qtp767266208-12308] o.a.d.a.s.i.ProjectWorkerGroupRelationServiceImpl:[155] - Success to add worker group [Linux-prod] for the project [测试] .
2025-10-27 15:05:32.125 INFO [qtp767266208-12308] o.a.d.a.s.i.ProjectWorkerGroupRelationServiceImpl:[155] - Success to add worker group [worker-10.10.243.142] for the project [测试] .

What you expected to happen

I have no idea

How to reproduce

assigned a worker group to project,

Anything else

No response

Version

3.3.1

Are you willing to submit PR?

• Yes I am willing to submit a PR!

Code of Conduct

• I agree to follow this project's Code of Conduct

[github-actions]

Search before asking

• I had searched in the issues and found no similar issues.

What happened

When I assigned a workgroup to a project, it prompted me: Failed to assign a workgroup to the project

api-server log

2025-10-27 15:04:22.235 ERROR [qtp767266208-12279] o.a.d.a.s.i.ProjectWorkerGroupRelationServiceImpl:[143] - Failed to delete worker groups [[worker-240.118]] for the project [运维].
2025-10-27 15:04:22.235 ERROR [qtp767266208-12279] o.a.d.a.e.ApiExceptionHandler:[40] - org.apache.dolphinscheduler.api.controller.ProjectWorkerGroupController#assignWorkerGroups[3 args] Meet a ServiceException: 给项目分配工作组失败

but, if i create a new project , can assign

2025-10-27 15:05:28.525 INFO [qtp767266208-12436] o.a.d.a.s.i.ProjectServiceImpl:[134] - Project is created and id is :7
2025-10-27 15:05:32.122 INFO [qtp767266208-12308] o.a.d.a.s.i.ProjectWorkerGroupRelationServiceImpl:[141] - Success to delete worker groups [[default, worker-240.118, Linux-prod, worker-10.10.243.142]] for the project [测试] .
2025-10-27 15:05:32.124 INFO [qtp767266208-12308] o.a.d.a.s.i.ProjectWorkerGroupRelationServiceImpl:[155] - Success to add worker group [default] for the project [测试] .
2025-10-27 15:05:32.124 INFO [qtp767266208-12308] o.a.d.a.s.i.ProjectWorkerGroupRelationServiceImpl:[155] - Success to add worker group [worker-240.118] for the project [测试] .
2025-10-27 15:05:32.125 INFO [qtp767266208-12308] o.a.d.a.s.i.ProjectWorkerGroupRelationServiceImpl:[155] - Success to add worker group [Linux-prod] for the project [测试] .
2025-10-27 15:05:32.125 INFO [qtp767266208-12308] o.a.d.a.s.i.ProjectWorkerGroupRelationServiceImpl:[155] - Success to add worker group [worker-10.10.243.142] for the project [测试] .

What you expected to happen

I have no idea

How to reproduce

assigned a worker group to project,

Anything else

No response

Version

3.3.1

Are you willing to submit PR?

• Yes I am willing to submit a PR!

Code of Conduct

• I agree to follow this project's Code of Conduct

[Mrhs121]

This difference can only handle the situation where a new wg is added. For instance, if p1 currently has only one wg w1, and you delete w1 and add w2, you can see that the value of the difference at this time is w2. Then, the following code will first delete w2, and an error will definitely occur at this point.

dolphinscheduler/dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/service/impl/ProjectWorkerGroupRelationServiceImpl.java

Lines 128 to 163 in 24e5997

	difference = SetUtils.difference(unauthorizedWorkerGroupNames, projectWorkerGroupNames);
	Date now = new Date();
	if (CollectionUtils.isNotEmpty(difference)) {
	Set<String> usedWorkerGroups = getAllUsedWorkerGroups(project);
	if (CollectionUtils.isNotEmpty(usedWorkerGroups) && usedWorkerGroups.containsAll(difference)) {
	throw new ServiceException(Status.USED_WORKER_GROUP_EXISTS,
	SetUtils.intersection(usedWorkerGroups, difference).toSet());
	}
	boolean deleted =
	projectWorkerGroupDao.deleteByProjectCodeAndWorkerGroups(projectCode, new ArrayList<>(difference));
	if (deleted) {
	log.info("Success to delete worker groups [{}] for the project [{}] .", difference, project.getName());
	} else {
	log.error("Failed to delete worker groups [{}] for the project [{}].", difference, project.getName());
	throw new ServiceException(Status.ASSIGN_WORKER_GROUP_TO_PROJECT_ERROR);
	}
	difference.forEach(workerGroupName -> {
	ProjectWorkerGroup projectWorkerGroup = new ProjectWorkerGroup();
	projectWorkerGroup.setProjectCode(projectCode);
	projectWorkerGroup.setWorkerGroup(workerGroupName);
	projectWorkerGroup.setCreateTime(now);
	projectWorkerGroup.setUpdateTime(now);
	int create = projectWorkerGroupDao.insert(projectWorkerGroup);
	if (create > 0) {
	log.info("Success to add worker group [{}] for the project [{}] .", workerGroupName,
	project.getName());
	} else {
	log.error("Failed to add worker group [{}] for the project [{}].", workerGroupName,
	project.getName());
	throw new ServiceException(Status.ASSIGN_WORKER_GROUP_TO_PROJECT_ERROR);
	}
	});
	}