WIP

Ferlab-Ste-Justine · Mar 9, 2024 · a145ba5 · a145ba5
1 parent a28364e
commit a145ba5
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/dags/etl_normalize_variants.py b/dags/etl_normalize_variants.py
@@ -9,7 +9,6 @@
                 '--config', default_config_file,
                 '--steps', 'default',
                 '--app-name', 'variant_task_consequences',
-                '--release-id', release_id,
                 '--owner', '{{ params.owner }}',
                 '--dataset', '{{ params.dataset }}',
                 '--batch', batch,
@@ -24,7 +23,8 @@
 })
 
 def normalize_variant_operator(name):
-    return normalized_etl.prepend_args(name).operator(
+    etl = normalized_etl.args('--release_id', release_id ) if name == 'snv' else normalized_etl
+    return etl.prepend_args(name).operator(
         task_id=f'normalize-{name}',
         name=f'normalize-{name}',
         env_vars=[