From a145ba5ae29b4d8e3afcbffe2f1b892a08ad1462 Mon Sep 17 00:00:00 2001
From: jecos <jcostanza@ferlab.bio>
Date: Fri, 8 Mar 2024 21:22:42 -0500
Subject: [PATCH] WIP

---
 dags/etl_normalize_variants.py | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/dags/etl_normalize_variants.py b/dags/etl_normalize_variants.py
index 250cf12..e19e8dd 100644
--- 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=[