Skip to content

Commit

Permalink
Merge branch 'refs/heads/master' into release_3
Browse files Browse the repository at this point in the history
  • Loading branch information
sunset666 committed Oct 7, 2024
2 parents 35eb941 + e740ae7 commit f86411f
Show file tree
Hide file tree
Showing 12 changed files with 6 additions and 14 deletions.
1 change: 0 additions & 1 deletion src/ingest-pipeline/airflow/dags/celldive_deepcell.py
Original file line number Diff line number Diff line change
Expand Up @@ -248,7 +248,6 @@ def build_cwltool_cwl_ome_tiff_pyramid(**kwargs):
# this is the call to the CWL
command = [
*get_cwltool_base_cmd(tmpdir),
"--relax-path-checks",
cwl_workflows["ome_tiff_pyramid"],
"--ometiff_directory",
".",
Expand Down
1 change: 0 additions & 1 deletion src/ingest-pipeline/airflow/dags/codex_cytokit.py
Original file line number Diff line number Diff line change
Expand Up @@ -394,7 +394,6 @@ def build_cwltool_cwl_ome_tiff_pyramid(**kwargs):
# this is the call to the CWL
command = [
*get_cwltool_base_cmd(tmpdir),
'--relax-path-checks',
cwl_workflows['ome_tiff_pyramid'],
'--ometiff_directory',
'.',
Expand Down
2 changes: 1 addition & 1 deletion src/ingest-pipeline/airflow/dags/cwl/portal-containers
1 change: 0 additions & 1 deletion src/ingest-pipeline/airflow/dags/mibi_deepcell.py
Original file line number Diff line number Diff line change
Expand Up @@ -241,7 +241,6 @@ def build_cwltool_cwl_ome_tiff_pyramid(**kwargs):
# this is the call to the CWL
command = [
*get_cwltool_base_cmd(tmpdir),
'--relax-path-checks',
cwl_workflows['ome_tiff_pyramid'],
'--ometiff_directory',
'.',
Expand Down
1 change: 0 additions & 1 deletion src/ingest-pipeline/airflow/dags/multiome.py
Original file line number Diff line number Diff line change
Expand Up @@ -123,7 +123,6 @@ def build_cwltool_cmd1(**kwargs):

command = [
*get_cwltool_base_cmd(tmpdir),
"--relax-path-checks",
"--outdir",
tmpdir / "cwl_out",
"--parallel",
Expand Down
1 change: 0 additions & 1 deletion src/ingest-pipeline/airflow/dags/pas_ftu_segmentation.py
Original file line number Diff line number Diff line change
Expand Up @@ -144,7 +144,6 @@ def build_cwltool_cwl_ome_tiff_pyramid(**kwargs):
# this is the call to the CWL
command = [
*get_cwltool_base_cmd(tmpdir),
"--relax-path-checks",
cwl_workflows["ome_tiff_pyramid"],
"--ometiff_directory",
".",
Expand Down
1 change: 0 additions & 1 deletion src/ingest-pipeline/airflow/dags/phenocycler_deepcell.py
Original file line number Diff line number Diff line change
Expand Up @@ -241,7 +241,6 @@ def build_cwltool_cwl_ome_tiff_pyramid(**kwargs):
# this is the call to the CWL
command = [
*get_cwltool_base_cmd(tmpdir),
"--relax-path-checks",
cwl_workflows["ome_tiff_pyramid"],
"--ometiff_directory",
".",
Expand Down
1 change: 0 additions & 1 deletion src/ingest-pipeline/airflow/dags/salmon_rnaseq.py
Original file line number Diff line number Diff line change
Expand Up @@ -105,7 +105,6 @@ def build_cwltool_cmd1(**kwargs):

command = [
*get_cwltool_base_cmd(tmpdir),
"--relax-path-checks",
"--outdir",
tmpdir / "cwl_out",
"--parallel",
Expand Down
1 change: 1 addition & 0 deletions src/ingest-pipeline/airflow/dags/utils.py
Original file line number Diff line number Diff line change
Expand Up @@ -1235,6 +1235,7 @@ def get_cwltool_base_cmd(tmpdir: Path) -> List[str]:
# are created as *subdirectories* of 'cwl-tmp' and 'cwl-out-tmp'.
"--tmpdir-prefix={}/".format(tmpdir / "cwl-tmp"),
"--tmp-outdir-prefix={}/".format(tmpdir / "cwl-out-tmp"),
"--relax-path-checks",
]


Expand Down
6 changes: 2 additions & 4 deletions src/ingest-pipeline/airflow/dags/visium.py
Original file line number Diff line number Diff line change
Expand Up @@ -105,7 +105,6 @@ def build_cwltool_cmd1(**kwargs):

command = [
*get_cwltool_base_cmd(tmpdir),
"--relax-path-checks",
"--outdir",
tmpdir / "cwl_out",
"--parallel",
Expand All @@ -122,10 +121,10 @@ def build_cwltool_cmd1(**kwargs):
command.append(data_dir / "raw/fastq/")

command.append("--img_dir")
command.append(data_dir / "lab_processed/images/")
command.append(data_dir)

command.append("--metadata_dir")
command.append(data_dir / "raw/")
command.append(data_dir)

return join_quote_command_str(command)

Expand Down Expand Up @@ -175,7 +174,6 @@ def build_cwltool_cmd4(**kwargs):
# this is the call to the CWL
command = [
*get_cwltool_base_cmd(tmpdir),
"--relax-path-checks",
cwl_workflows[3],
"--ometiff_directory",
data_dir / "lab_processed/images/",
Expand Down
2 changes: 1 addition & 1 deletion src/ingest-pipeline/airflow/dags/workflow_map.yml
Original file line number Diff line number Diff line change
Expand Up @@ -66,7 +66,7 @@ workflow_map:
'assay_type': 'sciATACseq'
'workflow': 'sc_atac_seq_sci'
- 'collection_type': 'generic_metadatatsv'
'assay_type': 'bulk RNA'
'assay_type': 'bulk-RNA'
'workflow': 'salmon_rnaseq_bulk'
- 'collection_type': 'generic_metadatatsv'
'assay_type': 'sciRNAseq'
Expand Down

0 comments on commit f86411f

Please sign in to comment.