Revision 5044
Added by daigle about 15 years ago
| lib/style/common/scheduledWorkflowResultset.xsl | ||
|---|---|---|
| 79 | 79 |
<xsl:choose> |
| 80 | 80 |
<xsl:when test="./status = 'scheduled'"> |
| 81 | 81 |
<xsl:attribute name="class">underlined</xsl:attribute> |
| 82 |
<xsl:attribute name="href"><xsl:value-of select='$servletURL' />?action=unscheduleWorkflow&workflowjobid=<xsl:value-of select='./name' />&workflowname=<xsl:value-of select='./jobParam[@name='workflowname']/value' />&workflowid=<xsl:value-of select='./jobParam[@name='workflowid']/value' />&qformat=<xsl:value-of select='$qformat' />&forwardto=scheduleWorkflowRun.jsp</xsl:attribute>
|
|
| 82 |
<xsl:attribute name="href"><xsl:value-of select='$servletURL' />?action=unscheduleWorkflow&workflowjobname=<xsl:value-of select='./name' />&workflowname=<xsl:value-of select='./jobParam[@name='workflowname']/value' />&workflowid=<xsl:value-of select='./jobParam[@name='workflowid']/value' />&qformat=<xsl:value-of select='$qformat' />&forwardto=scheduleWorkflowRun.jsp</xsl:attribute>
|
|
| 83 | 83 |
Unschedule |
| 84 | 84 |
</xsl:when> |
| 85 | 85 |
<xsl:otherwise> |
| 86 | 86 |
<xsl:attribute name="class">underlined</xsl:attribute> |
| 87 |
<xsl:attribute name="href"><xsl:value-of select='$servletURL' />?action=rescheduleWorkflow&workflowjobid=<xsl:value-of select='./name' />&workflowname=<xsl:value-of select='./jobParam[@name='workflowname']/value' />&workflowid=<xsl:value-of select='./jobParam[@name='workflowid']/value' />&qformat=<xsl:value-of select='$qformat' />&forwardto=scheduleWorkflowRun.jsp</xsl:attribute>
|
|
| 87 |
<xsl:attribute name="href"><xsl:value-of select='$servletURL' />?action=rescheduleWorkflow&workflowjobname=<xsl:value-of select='./name' />&workflowname=<xsl:value-of select='./jobParam[@name='workflowname']/value' />&workflowid=<xsl:value-of select='./jobParam[@name='workflowid']/value' />&qformat=<xsl:value-of select='$qformat' />&forwardto=scheduleWorkflowRun.jsp</xsl:attribute>
|
|
| 88 | 88 |
Reschedule |
| 89 | 89 |
</xsl:otherwise> |
| 90 | 90 |
</xsl:choose> |
| ... | ... | |
| 93 | 93 |
<xsl:when test="./status = 'unscheduled'"> |
| 94 | 94 |
<a> |
| 95 | 95 |
<xsl:attribute name="class">underlined</xsl:attribute> |
| 96 |
<xsl:attribute name="href"><xsl:value-of select='$servletURL' />?action=deleteScheduledWorkflow&workflowjobid=<xsl:value-of select='./name' />&&workflowname=<xsl:value-of select='./jobParam[@name='workflowname']/value' />&workflowid=<xsl:value-of select='./jobParam[@name='workflowid']/value' />&qformat=<xsl:value-of select='$qformat' />&forwardto=scheduleWorkflowRun.jsp</xsl:attribute>
|
|
| 96 |
<xsl:attribute name="href"><xsl:value-of select='$servletURL' />?action=deleteScheduledWorkflow&workflowjobname=<xsl:value-of select='./name' />&&workflowname=<xsl:value-of select='./jobParam[@name='workflowname']/value' />&workflowid=<xsl:value-of select='./jobParam[@name='workflowid']/value' />&qformat=<xsl:value-of select='$qformat' />&forwardto=scheduleWorkflowRun.jsp</xsl:attribute>
|
|
| 97 | 97 |
Delete |
| 98 | 98 |
</a> |
| 99 | 99 |
</xsl:when> |
| src/edu/ucsb/nceas/workflowscheduler/WorkflowScheduler.java | ||
|---|---|---|
| 199 | 199 |
* @param groups |
| 200 | 200 |
* the user's group |
| 201 | 201 |
*/ |
| 202 |
public void unScheduleJob(HttpServletRequest request, HttpServletResponse response,
|
|
| 202 |
public void unscheduleJob(HttpServletRequest request, HttpServletResponse response,
|
|
| 203 | 203 |
Hashtable<String, String[]> params, String username, String[] groups) |
| 204 | 204 |
throws MetacatSchedulerException {
|
| 205 | 205 |
try {
|
| 206 | 206 |
// workflow job id must exist |
| 207 |
String jobNames[] = params.get("workflowjobid");
|
|
| 207 |
String jobNames[] = params.get("workflowjobname");
|
|
| 208 | 208 |
if (jobNames == null || jobNames.length == 0) {
|
| 209 |
throw new MetacatSchedulerException("SchedulerService.unScheduleJob - workflowjobid "
|
|
| 209 |
throw new MetacatSchedulerException("SchedulerService.unScheduleJob - workflowjobname "
|
|
| 210 | 210 |
+ "field must be populated in scheduler parameters when unscheduling job."); |
| 211 | 211 |
} |
| 212 | 212 |
String jobName = jobNames[0]; |
| 213 | 213 |
|
| 214 | 214 |
// unschedule the job |
| 215 | 215 |
SchedulerService schedulerService = SchedulerService.getInstance(); |
| 216 |
String xmlResult = schedulerService.unScheduleJob(jobName, username, groups);
|
|
| 216 |
String xmlResult = schedulerService.unscheduleJob(jobName, username, groups);
|
|
| 217 | 217 |
|
| 218 | 218 |
ResponseUtil.sendSuccessXML(response, xmlResult); |
| 219 | 219 |
|
| ... | ... | |
| 240 | 240 |
* @param groups |
| 241 | 241 |
* the user's group |
| 242 | 242 |
*/ |
| 243 |
public void reScheduleJob(HttpServletRequest request, HttpServletResponse response,
|
|
| 243 |
public void rescheduleJob(HttpServletRequest request, HttpServletResponse response,
|
|
| 244 | 244 |
Hashtable<String, String[]> params, String username, |
| 245 | 245 |
String[] groups) throws MetacatSchedulerException {
|
| 246 | 246 |
|
| 247 | 247 |
try {
|
| 248 | 248 |
// workflow job id must exist |
| 249 |
String jobNames[] = params.get("workflowjobid");
|
|
| 249 |
String jobNames[] = params.get("workflowjobname");
|
|
| 250 | 250 |
if (jobNames == null || jobNames.length == 0) {
|
| 251 |
throw new MetacatSchedulerException("WorkflowScheduler.reScheduleJob - workflowjobid field must be populated "
|
|
| 251 |
throw new MetacatSchedulerException("WorkflowScheduler.reScheduleJob - workflowjobname field must be populated "
|
|
| 252 | 252 |
+ "in scheduler parameters when rescheduling job."); |
| 253 | 253 |
} |
| 254 | 254 |
String jobName = jobNames[0]; |
| ... | ... | |
| 281 | 281 |
Hashtable<String, String[]> params, String username, String[] groups) throws MetacatSchedulerException {
|
| 282 | 282 |
try {
|
| 283 | 283 |
// workflow job id must exist |
| 284 |
String jobNames[] = params.get("workflowjobid");
|
|
| 284 |
String jobNames[] = params.get("workflowjobname");
|
|
| 285 | 285 |
if (jobNames == null || jobNames.length == 0) {
|
| 286 | 286 |
throw new MetacatSchedulerException( |
| 287 | 287 |
"WorkflowScheduler.deleteJob - workflowname field must be populated " |
| src/edu/ucsb/nceas/workflowscheduler/WorkflowSchedulerServlet.java | ||
|---|---|---|
| 87 | 87 |
* removes it from the scheduling engine and changes the |
| 88 | 88 |
* status in the scheduled_job table to " unscheduled. Note |
| 89 | 89 |
* that this may be extracted into a separate servlet. |
| 90 |
* workflowjobid -- The job ID for the workflow run that we want to unschedule. This
|
|
| 90 |
* workflowjobname -- The job ID for the workflow run that we want to unschedule. This
|
|
| 91 | 91 |
* is held in the database as scheduled_job.name |
| 92 | 92 |
* forwardto -- If provided, forward to this page when processing is done. |
| 93 | 93 |
* qformat -- If provided, render results using the stylesheets associated with |
| ... | ... | |
| 96 | 96 |
* registers it with the scheduling engine and changes the |
| 97 | 97 |
* status in the scheduled_job table to " scheduled. Note |
| 98 | 98 |
* that this may be extracted into a separate servlet. |
| 99 |
* workflowjobid -- The job ID for the workflow run that we want to reschedule. This
|
|
| 99 |
* workflowjobname -- The job ID for the workflow run that we want to reschedule. This
|
|
| 100 | 100 |
* is held in the database as scheduled_job.name |
| 101 | 101 |
* forwardto -- If provided, forward to this page when processing is done. |
| 102 | 102 |
* qformat -- If provided, render results using the stylesheets associated with |
| ... | ... | |
| 105 | 105 |
* removes it from the scheduling engine and changes the |
| 106 | 106 |
* status in the scheduled_job table to " deleted. Note |
| 107 | 107 |
* that this may be extracted into a separate servlet. |
| 108 |
* workflowjobid -- The job ID for the workflow run that we want to delete. This
|
|
| 108 |
* workflowjobname -- The job ID for the workflow run that we want to delete. This
|
|
| 109 | 109 |
* is held in the database as scheduled_job.name |
| 110 | 110 |
* forwardto -- If provided, forward to this page when processing is done. |
| 111 | 111 |
* qformat -- If provided, render results using the stylesheets associated with |
| ... | ... | |
| 332 | 332 |
} |
| 333 | 333 |
} else if (action.equals("unscheduleWorkflow")) {
|
| 334 | 334 |
try {
|
| 335 |
WorkflowScheduler.getInstance().unScheduleJob(request, response,
|
|
| 335 |
WorkflowScheduler.getInstance().unscheduleJob(request, response,
|
|
| 336 | 336 |
params, userName, groupNames); |
| 337 | 337 |
return; |
| 338 | 338 |
} catch (BaseException be) {
|
| ... | ... | |
| 344 | 344 |
} |
| 345 | 345 |
} else if (action.equals("rescheduleWorkflow")) {
|
| 346 | 346 |
try {
|
| 347 |
WorkflowScheduler.getInstance().reScheduleJob(request, response,
|
|
| 347 |
WorkflowScheduler.getInstance().rescheduleJob(request, response,
|
|
| 348 | 348 |
params, userName, groupNames); |
| 349 | 349 |
return; |
| 350 | 350 |
} catch (BaseException be) {
|
| src/edu/ucsb/nceas/metacat/scheduler/SchedulerService.java | ||
|---|---|---|
| 123 | 123 |
// Stop the scheduler |
| 124 | 124 |
public void stop() throws ServiceException {
|
| 125 | 125 |
try {
|
| 126 |
sched.shutdown(true);
|
|
| 126 |
sched.shutdown(); |
|
| 127 | 127 |
sched = null; |
| 128 | 128 |
} catch (SchedulerException se) {
|
| 129 | 129 |
throw new ServiceException("SchedulerService.stop - Could not shut down scheduler: " + se.getMessage());
|
| ... | ... | |
| 297 | 297 |
* the user's group name |
| 298 | 298 |
* @return a message saying the job was unscheduled |
| 299 | 299 |
*/ |
| 300 |
public String unScheduleJob(String jobName, String username,
|
|
| 300 |
public String unscheduleJob(String jobName, String username,
|
|
| 301 | 301 |
String[] groups) throws ServiceException {
|
| 302 | 302 |
|
| 303 | 303 |
ScheduledJobDAO jobDAO = null; |
| ... | ... | |
| 412 | 412 |
+ "job : " + jobDAO.getName() + " due to a utility issue: " + ue.getMessage()); |
| 413 | 413 |
} |
| 414 | 414 |
|
| 415 |
return "Resheduled: " + jobDAO.getName(); |
|
| 415 |
return "Rescheduled: " + jobDAO.getName();
|
|
| 416 | 416 |
} |
| 417 | 417 |
|
| 418 | 418 |
/** |
Also available in: Unified diff
change name of workflowjobid parameter to be workflowjobname which is more accurate