[Cogkit-svn] SF.net SVN: cogkit: [1964] trunk/current/src/cog/modules/provider-gt2/src/ org/globus/cog/abstraction/impl/execution/gt2/JobSubmissionTaskHandler.java

[<ha...@us...>]

Revision: 1964
          http://cogkit.svn.sourceforge.net/cogkit/?rev=1964&view=rev
Author:   hategan
Date:     2008-04-21 20:22:39 -0700 (Mon, 21 Apr 2008)

Log Message:
-----------
properly handle job managers

Modified Paths:
--------------
    trunk/current/src/cog/modules/provider-gt2/src/org/globus/cog/abstraction/impl/execution/gt2/JobSubmissionTaskHandler.java

Modified: trunk/current/src/cog/modules/provider-gt2/src/org/globus/cog/abstraction/impl/execution/gt2/JobSubmissionTaskHandler.java
===================================================================
--- trunk/current/src/cog/modules/provider-gt2/src/org/globus/cog/abstraction/impl/execution/gt2/JobSubmissionTaskHandler.java	2008-04-18 03:30:35 UTC (rev 1963)
+++ trunk/current/src/cog/modules/provider-gt2/src/org/globus/cog/abstraction/impl/execution/gt2/JobSubmissionTaskHandler.java	2008-04-22 03:22:39 UTC (rev 1964)
@@ -20,9 +20,11 @@
 import org.globus.cog.abstraction.impl.common.task.TaskSubmissionException;
 import org.globus.cog.abstraction.interfaces.DelegatedTaskHandler;
 import org.globus.cog.abstraction.interfaces.Delegation;
+import org.globus.cog.abstraction.interfaces.ExecutionService;
 import org.globus.cog.abstraction.interfaces.FileLocation;
 import org.globus.cog.abstraction.interfaces.JobSpecification;
 import org.globus.cog.abstraction.interfaces.SecurityContext;
+import org.globus.cog.abstraction.interfaces.Service;
 import org.globus.cog.abstraction.interfaces.ServiceContact;
 import org.globus.cog.abstraction.interfaces.Status;
 import org.globus.cog.abstraction.interfaces.Task;
@@ -126,8 +128,11 @@
         String server = serviceContact.getContact();
 
         // if the jobmanager attribute is specified, handle it
-        String jobmanager = (String) this.task.getService(0).getAttribute(
-                "jobmanager");
+        Service service = this.task.getService(0);
+        String jobmanager = null;
+        if (service instanceof ExecutionService) {
+            jobmanager = ((ExecutionService) service).getJobManager();
+        }
         if (jobmanager != null) {
             server = handleJobManager(server, jobmanager);
         }


This was sent by the SourceForge.net collaborative development platform, the world's largest Open Source development site.