adding idempotent parameter to hail init for azure

aehrc · Sep 7, 2022 · e64eb92 · e64eb92
1 parent 995f258
commit e64eb92
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/pom.xml b/pom.xml
@@ -4,7 +4,7 @@
   <modelVersion>4.0.0</modelVersion>
   <groupId>au.csiro.aehrc.variant-spark</groupId>
   <artifactId>variant-spark_2.12</artifactId>
-  <version>0.5.2-SNAPSHOT</version>
+  <version>0.5.2</version>
   <packaging>jar</packaging>
 
   <name>variant-spark</name>

diff --git a/python/varspark/hail/context.py b/python/varspark/hail/context.py
@@ -7,7 +7,7 @@
 import varspark as vs
 
 
-def init(sc=None, quiet=False, spark_conf=None, **kwargs):
+def init(sc=None, idempotent=False, quiet=False, spark_conf=None, **kwargs):
     """ Initialises hail context with variant-spark support.
 
         :param kwargs: same as for hail.init()
@@ -20,7 +20,7 @@ def init(sc=None, quiet=False, spark_conf=None, **kwargs):
         sys.stderr.write("using variant-spark jar at '%s'\n" % vs_jar_path)
     if not vs_jar_path in jars:
         jars.append(vs_jar_path)
-    hl.init(sc=sc, quiet=quiet, spark_conf={'spark.jars': ",".join(jars)}, **kwargs)
+    hl.init(sc=sc, idempotent=idempotent, quiet=quiet, spark_conf={'spark.jars': ",".join(jars)}, **kwargs)
 
 
 def version():