You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airavata.apache.org by sa...@apache.org on 2013/06/07 20:57:37 UTC
svn commit: r1490783 -
/airavata/trunk/modules/gfac-core/src/main/java/org/apache/airavata/gfac/provider/impl/LocalProvider.java
Author: samindaw
Date: Fri Jun 7 18:57:37 2013
New Revision: 1490783
URL: http://svn.apache.org/r1490783
Log:
updating status more frequetly
Modified:
airavata/trunk/modules/gfac-core/src/main/java/org/apache/airavata/gfac/provider/impl/LocalProvider.java
Modified: airavata/trunk/modules/gfac-core/src/main/java/org/apache/airavata/gfac/provider/impl/LocalProvider.java
URL: http://svn.apache.org/viewvc/airavata/trunk/modules/gfac-core/src/main/java/org/apache/airavata/gfac/provider/impl/LocalProvider.java?rev=1490783&r1=1490782&r2=1490783&view=diff
==============================================================================
--- airavata/trunk/modules/gfac-core/src/main/java/org/apache/airavata/gfac/provider/impl/LocalProvider.java (original)
+++ airavata/trunk/modules/gfac-core/src/main/java/org/apache/airavata/gfac/provider/impl/LocalProvider.java Fri Jun 7 18:57:37 2013
@@ -127,7 +127,7 @@ public class LocalProvider implements GF
try {
// running cmd
Process process = builder.start();
- jobId="Local_"+Calendar.getInstance().getTimeInMillis()+"_";
+ jobId="Local_"+Calendar.getInstance().getTimeInMillis();
if(jobExecutionContext.getGFacConfiguration().getAiravataAPI() != null){
ApplicationJob appJob = GFacUtils.createApplicationJob(jobExecutionContext);
appJob.setJobId(jobId);
@@ -149,6 +149,13 @@ public class LocalProvider implements GF
e.printStackTrace();
}
}
+ if(jobExecutionContext.getGFacConfiguration().getAiravataAPI() != null){
+ try {
+ jobExecutionContext.getGFacConfiguration().getAiravataAPI().getProvenanceManager().updateApplicationJobStatus(jobId, ApplicationJobStatus.INITIALIZE, Calendar.getInstance().getTime());
+ } catch (AiravataAPIInvocationException e) {
+ e.printStackTrace();
+ }
+ }
Thread standardOutWriter = new InputStreamToFileWriter(process.getInputStream(), app.getStandardOutput());
Thread standardErrorWriter = new InputStreamToFileWriter(process.getErrorStream(), app.getStandardError());
@@ -157,7 +164,13 @@ public class LocalProvider implements GF
standardErrorWriter.setDaemon(true);
standardOutWriter.start();
standardErrorWriter.start();
-
+ if(jobExecutionContext.getGFacConfiguration().getAiravataAPI() != null){
+ try {
+ jobExecutionContext.getGFacConfiguration().getAiravataAPI().getProvenanceManager().updateApplicationJobStatus(jobId, ApplicationJobStatus.EXECUTING, Calendar.getInstance().getTime());
+ } catch (AiravataAPIInvocationException e) {
+ e.printStackTrace();
+ }
+ }
// wait for the process (application) to finish executing
int returnValue = process.waitFor();