■ ■ ■ ■ ■ ■
server-core/src/main/java/io/onedev/server/buildspec/job/DefaultJobManager.java
| skipped 169 lines |
170 | 170 | | |
171 | 171 | | @Transactional |
172 | 172 | | @Override |
173 | | - | public Build submit(Project project, ObjectId commitId, String jobName, String triggerId, |
| 173 | + | public Build submit(Project project, ObjectId commitId, String jobName, |
174 | 174 | | Map<String, List<String>> paramMap, SubmitReason reason) { |
175 | 175 | | Lock lock = LockUtils.getLock("job-manager: " + project.getId() + "-" + commitId.name()); |
176 | 176 | | transactionManager.mustRunAfterTransaction(new Runnable() { |
| skipped 11 lines |
188 | 188 | | |
189 | 189 | | validate(project, commitId); |
190 | 190 | | |
191 | | - | return submit(project, commitId, jobName, triggerId, paramMap, reason, new LinkedHashSet<>()); |
| 191 | + | return submit(project, commitId, jobName, paramMap, reason, new LinkedHashSet<>()); |
192 | 192 | | } catch (Throwable e) { |
193 | 193 | | throw ExceptionUtils.unchecked(e); |
194 | 194 | | } |
195 | 195 | | } |
196 | 196 | | |
197 | | - | private Build submit(Project project, ObjectId commitId, String jobName, String triggerId, |
| 197 | + | private Build submit(Project project, ObjectId commitId, String jobName, |
198 | 198 | | Map<String, List<String>> paramMap, SubmitReason reason, Set<String> checkedJobNames) { |
199 | 199 | | |
200 | 200 | | ScriptIdentity.push(new JobIdentity(project, commitId)); |
| skipped 2 lines |
203 | 203 | | build.setProject(project); |
204 | 204 | | build.setCommitHash(commitId.name()); |
205 | 205 | | build.setJobName(jobName); |
206 | | - | build.setTriggerId(triggerId); |
207 | 206 | | build.setSubmitDate(new Date()); |
208 | 207 | | build.setStatus(Build.Status.WAITING); |
209 | 208 | | build.setSubmitReason(reason.getDescription()); |
| skipped 15 lines |
225 | 224 | | } |
226 | 225 | | |
227 | 226 | | Collection<Build> builds = buildManager.query(project, commitId, jobName, |
228 | | - | reason.getRefName(), reason.getPullRequest(), triggerId, paramMapToQuery); |
| 227 | + | reason.getRefName(), reason.getPullRequest(), paramMapToQuery); |
229 | 228 | | |
230 | 229 | | if (builds.isEmpty()) { |
231 | 230 | | for (Map.Entry<String, List<String>> entry: paramMap.entrySet()) { |
| skipped 24 lines |
256 | 255 | | @Override |
257 | 256 | | public void run(Map<String, List<String>> params) { |
258 | 257 | | Build dependencyBuild = submit(project, commitId, dependency.getJobName(), |
259 | | - | triggerId, params, reason, new LinkedHashSet<>(checkedJobNames)); |
| 258 | + | params, reason, new LinkedHashSet<>(checkedJobNames)); |
260 | 259 | | BuildDependence dependence = new BuildDependence(); |
261 | 260 | | dependence.setDependency(dependencyBuild); |
262 | 261 | | dependence.setDependent(build); |
| skipped 362 lines |
625 | 624 | | |
626 | 625 | | @Override |
627 | 626 | | public void run(Map<String, List<String>> paramMap) { |
628 | | - | submit(project, commitId, job.getName(), event.getUuid(), |
629 | | - | paramMap, match.getReason()); |
| 627 | + | submit(project, commitId, job.getName(), paramMap, match.getReason()); |
630 | 628 | | } |
631 | 629 | | |
632 | 630 | | }.run(); |
| skipped 379 lines |