You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airavata.apache.org by la...@apache.org on 2013/05/04 09:14:38 UTC

svn commit: r1479051 - /airavata/trunk/modules/xbaya-gui/src/main/java/org/apache/airavata/xbaya/interpretor/WorkflowInterpreter.java

Author: lahiru
Date: Sat May  4 07:14:38 2013
New Revision: 1479051

URL: http://svn.apache.org/r1479051
Log:
removing threading with each node due to unstability

Modified:
    airavata/trunk/modules/xbaya-gui/src/main/java/org/apache/airavata/xbaya/interpretor/WorkflowInterpreter.java

Modified: airavata/trunk/modules/xbaya-gui/src/main/java/org/apache/airavata/xbaya/interpretor/WorkflowInterpreter.java
URL: http://svn.apache.org/viewvc/airavata/trunk/modules/xbaya-gui/src/main/java/org/apache/airavata/xbaya/interpretor/WorkflowInterpreter.java?rev=1479051&r1=1479050&r2=1479051&view=diff
==============================================================================
--- airavata/trunk/modules/xbaya-gui/src/main/java/org/apache/airavata/xbaya/interpretor/WorkflowInterpreter.java (original)
+++ airavata/trunk/modules/xbaya-gui/src/main/java/org/apache/airavata/xbaya/interpretor/WorkflowInterpreter.java Sat May  4 07:14:38 2013
@@ -198,18 +198,18 @@ public class WorkflowInterpreter {
 					}
 
                     // Since this is an independent node execution we can run these nodes in separate threads.
-                    Thread th = new Thread() {
-
-                        public synchronized void run() {
-                            try {
+//                    Thread th = new Thread() {
+//
+//                        public synchronized void run() {
+//                            try {
                                 executeDynamically(node);
-                            } catch (WorkflowException e) {
-                                log.error("Error execution workflow Node : " + node.getID());
-                                return;
-                            }
-                        }
-                    };
-                    th.start();
+//                            } catch (WorkflowException e) {
+//                                log.error("Error execution workflow Node : " + node.getID());
+//                                return;
+//                            }
+//                        }
+//                    };
+//                    th.start();
 					if (this.getWorkflow().getExecutionState() == WorkflowExecutionState.STEP) {
 						this.getWorkflow().setExecutionState(WorkflowExecutionState.PAUSED);
 						break;