Release 2.0

gga_load_data.py:

• Factorize goto_species_dir(), create_galaxy_instance(), run_tool(), get_species_dir()
• Move constants at the beginning
• Revert upload_from_local() to upload_from_galaxy_fs() (to enable symlink, instead of copy)
• Add missing get_bam_label()

README:

• update contributors

gga_load_data.py

@@ -10,6 +10,7 @@ import sys
 import time
 import json
 import yaml
+import subprocess
 
 from bioblend import galaxy
 from bioblend.galaxy.objects import GalaxyInstance
@@ -142,7 +143,7 @@ class LoadData(speciesData.SpeciesData):
 
             for fname, files in folders.items():
                 if fname and files:
-                    folder_name = re.sub(data_dir_root, "", fname)
+                    folder_name = re.sub(data_dir_root + "/", "", fname)
                     logging.info("Creating folder: %s" % folder_name)
                     folder = self.create_deep_folder(prj_lib, folder_name)
 
@@ -209,19 +210,19 @@ class LoadData(speciesData.SpeciesData):
         logging.info("Waiting for import jobs to finish... please wait")
 
         # Checking job state (only necessary if ran using SLURM)
-        # while True:
-        #     try:
-        #         # "C" state means the job is completed, no need to wait for it
-        #         ret = subprocess.check_output("squeue | grep -v \"C debug\" | grep -v \"JOBID\" || true",
-        #                                       shell=True)
-        #         if not len(ret):
-        #             break
-        #         time.sleep(3)
-        #     except subprocess.CalledProcessError as inst:
-        #         if inst.returncode == 153:  # queue is empty
-        #             break
-        #         else:
-        #             raise
+        while True:
+            try:
+                # "C" state means the job is completed, no need to wait for it
+                ret = subprocess.check_output("squeue | grep -v \"C debug\" | grep -v \"JOBID\" || true",
+                                              shell=True)
+                if not len(ret):
+                    break
+                time.sleep(3)
+            except subprocess.CalledProcessError as inst:
+                if inst.returncode == 153:  # queue is empty
+                    break
+                else:
+                    raise
 
         time.sleep(10)