1 files changed, 6 insertions, 9 deletions

diff --git a/src/main/java/com/c2kernel/entity/proxy/AgentProxy.java b/src/main/java/com/c2kernel/entity/proxy/AgentProxy.java
index 24172dc..d803079 100644
--- a/src/main/java/com/c2kernel/entity/proxy/AgentProxy.java
+++ b/src/main/java/com/c2kernel/entity/proxy/AgentProxy.java
@@ -25,7 +25,6 @@ import com.c2kernel.entity.C2KLocalObject;
 import com.c2kernel.entity.ManageableEntity;

 import com.c2kernel.entity.agent.Job;

 import com.c2kernel.lifecycle.instance.predefined.PredefinedStep;

-import com.c2kernel.lifecycle.instance.stateMachine.Transitions;

 import com.c2kernel.lookup.AgentPath;

 import com.c2kernel.lookup.DomainPath;

 import com.c2kernel.lookup.EntityPath;

@@ -111,14 +110,13 @@ public class AgentProxy extends EntityProxy
         ScriptErrorException

     {

         OutcomeValidator validator = null;

-        String scriptName = job.getActPropString("ScriptName");

         Date startTime = new Date();

         Logger.msg(3, "AgentProxy - executing "+job.getStepPath()+" for "+path.getAgentName());

         // get the outcome validator if present

-        if (job.requiresOutcome() || job.isError())

+        if (job.hasOutcome())

         {

-        	String schemaName = job.isError()?"Errors":job.getSchemaType();

-        	int schemaVersion = job.isError()?0:job.getSchemaVersion();

+        	String schemaName = job.getSchemaName();

+        	int schemaVersion = job.getSchemaVersion();

 

             Logger.msg(5, "AgentProxy - fetching schema "+schemaName+"_"+schemaVersion+" for validation");

             // retrieve schema

@@ -134,9 +132,8 @@ public class AgentProxy extends EntityProxy
             }

         }

 

-        if(scriptName != null && scriptName.length() > 0 &&

-            (job.getPossibleTransition() == Transitions.DONE || job.getPossibleTransition() == Transitions.COMPLETE)) {

-            Logger.msg(3, "AgentProxy - executing script "+scriptName);

+        if(job.hasScript()) {

+            Logger.msg(3, "AgentProxy - executing script "+job.getScriptName()+" v"+job.getScriptVersion());

             try {

 

                 // pre-validate outcome from script if there is one

@@ -151,7 +148,6 @@ public class AgentProxy extends EntityProxy
 

                 // load script

                 ErrorInfo scriptErrors = (ErrorInfo)callScript(item, job);

-

                 String errorString = scriptErrors.toString();

                 if (scriptErrors.getFatal()) {

                     Logger.msg(3, "AgentProxy - fatal script error");

@@ -171,6 +167,7 @@ public class AgentProxy extends EntityProxy
             if (error.length() > 0)

                 throw new InvalidDataException(error, "");

         }

+        else if (job.isOutcomeRequired())

 

         job.setAgentId(getSystemKey());

         Logger.msg(3, "AgentProxy - submitting job to item proxy");