diff --git a/da/tools/pipeline.py b/da/tools/pipeline.py
index 16736f35ca3251843387a0f0a018687f75524141..800ef9ea117f193cbca59ade06df678bc4a70b97 100755
--- a/da/tools/pipeline.py
+++ b/da/tools/pipeline.py
@@ -195,6 +195,8 @@ def Advance( DaCycle, StateVector):
 
     return None
 
+
+
 def SaveAndSubmit( DaCycle, StateVector):
     """ Save the model state and submit the next job """
 
@@ -358,4 +360,12 @@ def Optimize(DaCycle, StateVector):
 
 
 if __name__ == "__main__":
-    pass
+
+    jobparams               = {'jobname':'das.jobinut'}
+    template                = DaPlatForm.GetJobTemplate(jobparams)
+    template                += 'cd %s\n'%os.getcwd()
+    template                += './das.py','rc=%s process=jobinput' % self.da_settings['da.restart.fname']
+
+    jobfile                 = DaPlatForm.WriteJob(self,template,'cycle.%s.das'%cd)
+    jobid                   = DaPlatForm.SubmitJob(jobfile) 
+