From a3ffac4c9b657314eb155681ef164982b26325fb Mon Sep 17 00:00:00 2001
From: Nate Coraor <nate@bx.psu.edu>
Date: Wed, 16 Sep 2009 15:22:45 -0400
Subject: [PATCH] remove numpy egg

---
 eggs.ini                    |  2 --
 lib/galaxy/jobs/__init__.py | 10 ++++++++--
 2 files changed, 8 insertions(+), 4 deletions(-)

diff --git a/eggs.ini b/eggs.ini
index faac8f22cca..537b3c7445b 100644
--- a/eggs.ini
+++ b/eggs.ini
@@ -23,7 +23,6 @@ pysqlite = 2.3.5
 python_lzo = 1.08
 threadframe = 0.2
 guppy = 0.1.8
-numpy = 1.2.1
 
 [eggs:noplatform]
 Beaker = 1.4
@@ -63,7 +62,6 @@ nose = .dev_r101
 
 ; source location, necessary for scrambling
 [source]
-numpy = http://downloads.sourceforge.net/numpy/numpy-1.2.1.tar.gz
 bx_python = http://bitbucket.org/james_taylor/bx-python/get/4bf1f32e6b76.bz2
 Cheetah = http://voxel.dl.sourceforge.net/sourceforge/cheetahtemplate/Cheetah-1.0.tar.gz
 DRMAA_python = http://gridengine.sunsource.net/files/documents/7/36/DRMAA-python-0.2.tar.gz
diff --git a/lib/galaxy/jobs/__init__.py b/lib/galaxy/jobs/__init__.py
index 99a71974e60..92375b9be47 100644
--- a/lib/galaxy/jobs/__init__.py
+++ b/lib/galaxy/jobs/__init__.py
@@ -495,8 +495,14 @@ class JobWrapper( object ):
                     shutil.move( dataset_path.false_path, dataset_path.real_path )
                     log.debug( "finish(): Moved %s to %s" % ( dataset_path.false_path, dataset_path.real_path ) )
                 except ( IOError, OSError ):
-                    self.fail( "Job %s's output dataset(s) could not be read" % job.id )
-                    return
+                    # this can happen if Galaxy is restarted during the job's
+                    # finish method - the false_path file has already moved,
+                    # and when the job is recovered, it won't be found.
+                    if os.path.exists( dataset_path.real_path ) and os.stat( dataset_path.real_path ).st_size > 0:
+                        log.warning( "finish(): %s not found, but %s is not empty, so it will be used instead" % ( dataset_path.false_path, dataset_path.real_path ) )
+                    else:
+                        self.fail( "Job %s's output dataset(s) could not be read" % job.id )
+                        return
         job_context = ExpressionContext( dict( stdout = stdout, stderr = stderr ) )
         for dataset_assoc in job.output_datasets:
             context = self.get_dataset_finish_context( job_context, dataset_assoc.dataset.dataset )