Skip to content

Commit

Permalink
Merge pull request #40 from ssjunnebo/aviti
Browse files Browse the repository at this point in the history
Sync with Sara's latest version
  • Loading branch information
chuan-wang authored Oct 24, 2024
2 parents 340de28 + 8134461 commit c75ca89
Showing 1 changed file with 6 additions and 3 deletions.
9 changes: 6 additions & 3 deletions taca/element/Element_Runs.py
Original file line number Diff line number Diff line change
Expand Up @@ -650,7 +650,7 @@ def generate_demux_command(self, run_manifest, demux_dir):
def start_demux(self, run_manifest, demux_dir):
with chdir(self.run_dir):
cmd = self.generate_demux_command(run_manifest, demux_dir)
stderr_abspath = f"{self.run_dir}/bases2fastq_stderr.txt"
stderr_abspath = f"{self.run_dir}/bases2fastq_stderr.txt" #TODO: individual files for each sub-demux
try:
with open(stderr_abspath, "w") as stderr:
process = subprocess.Popen(
Expand Down Expand Up @@ -1198,8 +1198,11 @@ def sync_metadata(self):
dest = os.path.join(metadata_archive, self.NGI_run_id)
if not os.path.exists(dest):
os.makedirs(dest)
for f in files_to_copy:
shutil.copy(f, dest)
for f in files_to_copy: # UnassignedSequences.csv missing in NoIndex case
if os.path.exists(f):
shutil.copy(f, dest)
else:
logger.warning(f"File {f} missing for run {self.run}")

def make_transfer_indicator(self):
transfer_indicator = os.path.join(self.run_dir, ".rsync_ongoing")
Expand Down

0 comments on commit c75ca89

Please sign in to comment.