Merge branch 'master' into feat-keycloak

.bumpversion.cfg

@@ -1,5 +1,5 @@
 [bumpversion]
-current_version = 67.0.0
+current_version = 67.0.8
 commit = True
 tag = True
 tag_name = v{new_version}

cg/__init__.py

@@ -1,2 +1,2 @@
 __title__ = "cg"
-__version__ = "67.0.0"
+__version__ = "67.0.8"

cg/cli/workflow/fluffy/base.py

@@ -13,6 +13,7 @@
 
 ARGUMENT_CASE_ID = click.argument("case_id", required=True)
 OPTION_EXTERNAL_REF = click.option("-e", "--external-ref", is_flag=True)
+OPTION_USE_BWA_MEM = click.option("-b", "--use-bwa-mem", is_flag=True)
 
 LOG = logging.getLogger(__name__)
 
@@ -51,15 +52,27 @@ def create_samplesheet(context: CGConfig, case_id: str, dry_run: bool):
 @DRY_RUN
 @click.option("-c", "--config", help="Path to fluffy config in .json format")
 @OPTION_EXTERNAL_REF
+@OPTION_USE_BWA_MEM
 @click.pass_obj
-def run(context: CGConfig, case_id: str, dry_run: bool, config: str, external_ref: bool = False):
+def run(
+    context: CGConfig,
+    case_id: str,
+    dry_run: bool,
+    config: str,
+    external_ref: bool,
+    use_bwa_mem: bool,
+):
     """
     Run Fluffy analysis
     """
     analysis_api: FluffyAnalysisAPI = context.meta_apis["analysis_api"]
     analysis_api.status_db.verify_case_exists(case_internal_id=case_id)
     analysis_api.run_fluffy(
-        case_id=case_id, workflow_config=config, dry_run=dry_run, external_ref=external_ref
+        case_id=case_id,
+        workflow_config=config,
+        dry_run=dry_run,
+        external_ref=external_ref,
+        use_bwa_mem=use_bwa_mem,
     )
     if dry_run:
         return
@@ -78,12 +91,14 @@ def run(context: CGConfig, case_id: str, dry_run: bool, config: str, external_re
 @DRY_RUN
 @click.option("-c", "--config", help="Path to fluffy config in .json format")
 @OPTION_EXTERNAL_REF
+@OPTION_USE_BWA_MEM
 @click.pass_context
 def start(
     context: click.Context,
     case_id: str,
     dry_run: bool,
-    external_ref: bool = False,
+    external_ref: bool,
+    use_bwa_mem: bool,
     config: str = None,
 ):
     """
@@ -96,7 +111,14 @@ def start(
     analysis_api.prepare_fastq_files(case_id=case_id, dry_run=dry_run)
     context.invoke(link, case_id=case_id, dry_run=dry_run)
     context.invoke(create_samplesheet, case_id=case_id, dry_run=dry_run)
-    context.invoke(run, case_id=case_id, config=config, dry_run=dry_run, external_ref=external_ref)
+    context.invoke(
+        run,
+        case_id=case_id,
+        config=config,
+        dry_run=dry_run,
+        external_ref=external_ref,
+        use_bwa_mem=use_bwa_mem,
+    )
 
 
 @fluffy.command("start-available")

cg/constants/scout.py

@@ -106,6 +106,7 @@ class ScoutUploadKey(StrEnum):
 
 RAREDISEASE_SAMPLE_TAGS: dict[str, set[str]] = dict(
     alignment_file={AlignmentFileTag.CRAM},
+    d4_file={"d4"},
     vcf2cytosure={"vcf2cytosure"},
     mt_bam={"bam-mt"},
     eklipse_path={"eklipse-png"},

cg/meta/upload/scout/hk_tags.py

@@ -71,6 +71,7 @@ class SampleTags(BaseModel):
     bam_file: set[str] | None = None
     alignment_file: set[str] | None = None
     alignment_path: set[str] | None = None
+    d4_file: set[str] | None = None
     vcf2cytosure: set[str] | None = None
     eklipse_path: set[str] | None = None
     mt_bam: set[str] | None = None

cg/meta/upload/scout/raredisease_config_builder.py

@@ -6,11 +6,7 @@
 from cg.apps.lims import LimsAPI
 from cg.apps.madeline.api import MadelineAPI
 from cg.constants.constants import FileFormat
-from cg.constants.housekeeper_tags import (
-    HK_DELIVERY_REPORT_TAG,
-    AnalysisTag,
-    NFAnalysisTags,
-)
+from cg.constants.housekeeper_tags import HK_DELIVERY_REPORT_TAG, AnalysisTag, NFAnalysisTags
 from cg.constants.scout import (
     RANK_MODEL_THRESHOLD,
     RAREDISEASE_CASE_TAGS,
@@ -206,3 +202,6 @@ def include_sample_files(self, config_sample: ScoutRarediseaseIndividual) -> Non
         config_sample.mitodel_file = self.get_sample_file(
             hk_tags=self.sample_tags.mitodel_file, sample_id=sample_id
         )
+        config_sample.d4_file = self.get_sample_file(
+            hk_tags=self.sample_tags.d4_file, sample_id=sample_id
+        )

cg/meta/workflow/fluffy.py

@@ -227,7 +227,12 @@ def make_sample_sheet(self, case_id: str, dry_run: bool) -> None:
             fluffy_sample_sheet.write_sample_sheet(sample_sheet_out_path)
 
     def run_fluffy(
-        self, case_id: str, dry_run: bool, workflow_config: str, external_ref: bool = False
+        self,
+        case_id: str,
+        dry_run: bool,
+        workflow_config: str,
+        external_ref: bool,
+        use_bwa_mem: bool,
     ) -> None:
         """
         Call fluffy with the configured command-line arguments
@@ -239,10 +244,8 @@ def run_fluffy(
                 shutil.rmtree(output_path, ignore_errors=True)
         if not workflow_config:
             workflow_config = self.fluffy_config.as_posix()
-        if not external_ref:
-            batch_ref_flag = "--batch-ref"
-        else:
-            batch_ref_flag = ""
+        batch_ref_flag = "" if external_ref else "--batch-ref"
+        use_bwa_mem_flag = "--bwa-mem" if use_bwa_mem else ""
         command_args = [
             "--config",
             workflow_config,
@@ -254,6 +257,7 @@ def run_fluffy(
             self.get_output_path(case_id=case_id).as_posix(),
             "--analyse",
             batch_ref_flag,
+            use_bwa_mem_flag,
             "--slurm_params",
             self.get_slurm_param_qos(case_id=case_id),
         ]

cg/models/scout/scout_load_config.py

@@ -93,6 +93,7 @@ class ScoutRarediseaseIndividual(ScoutIndividual):
     vcf2cytosure: str | None = None
     mitodel_file: str | None = None
     reviewer: Reviewer = Reviewer()
+    d4_file: str | None = None
 
 
 class ScoutCancerIndividual(ScoutIndividual):