Skip to content

Commit

Permalink
Use public attribute (#87)
Browse files Browse the repository at this point in the history
Signed-off-by: noklam <nok.lam.chan@quantumblack.com>
  • Loading branch information
noklam authored May 9, 2022
1 parent b126ede commit b08682a
Show file tree
Hide file tree
Showing 2 changed files with 2 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -32,7 +32,7 @@ def init_spark_session(self) -> None:
"""

# Load the spark configuration in spark.yaml using the config loader
parameters = self._config_loader.get("spark*", "spark*/**")
parameters = self.config_loader.get("spark*", "spark*/**")
spark_conf = SparkConf().setAll(parameters.items())

# Initialise the spark session
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -32,7 +32,7 @@ def init_spark_session(self) -> None:
"""

# Load the spark configuration in spark.yaml using the config loader
parameters = self._config_loader.get("spark*", "spark*/**")
parameters = self.config_loader.get("spark*", "spark*/**")
spark_conf = SparkConf().setAll(parameters.items())

# Initialise the spark session
Expand Down

0 comments on commit b08682a

Please sign in to comment.