fix (#11)

grusin-db · web-flow · commit b1f1d7031825 · 2023-06-30T14:57:45.000+02:00
diff --git a/bdq/__init__.py b/bdq/__init__.py
@@ -1,4 +1,4 @@
-__version__ = "0.0.3"
+__version__ = "0.0.4"
 
 from pyspark.sql import SparkSession
 spark = SparkSession.builder.getOrCreate()
diff --git a/bdq/dag.py b/bdq/dag.py
@@ -233,6 +233,7 @@ def _start(node: Node):
         running_nodes = running_nodes + 1
 
         node.future = executor.submit(node)
+        node._viz_update_state()
         
         if verbose:
           print(f"  starting: {node}")
diff --git a/pyproject.toml b/pyproject.toml
@@ -1,6 +1,6 @@
 [project]
 name = "bdq"
-version = "0.0.3"
+version = "0.0.4"
 authors = [
   { name="Grzegorz Rusin", email="grzegorz.rusin@databricks.com" },
 ]

Original file line number	Diff line number	Diff line change
`@@ -1,4 +1,4 @@`
`1`		`-__version__ = "0.0.3"`
	`1`	`+__version__ = "0.0.4"`
`2`	`2`
`3`	`3`	`from pyspark.sql import SparkSession`
`4`	`4`	`spark = SparkSession.builder.getOrCreate()`
Original file line number	Diff line number	Diff line change
`@@ -1,6 +1,6 @@`
`1`	`1`	`[project]`
`2`	`2`	`name = "bdq"`
`3`		`-version = "0.0.3"`
	`3`	`+version = "0.0.4"`
`4`	`4`	`authors = [`
`5`	`5`	`{ name="Grzegorz Rusin", email="grzegorz.rusin@databricks.com" },`
`6`	`6`	`]`