Skip to content

Commit

Permalink
fix(databricks): import method before use
Browse files Browse the repository at this point in the history
  • Loading branch information
pbullhove committed Oct 3, 2024
1 parent 733ef24 commit 26adaad
Showing 1 changed file with 1 addition and 3 deletions.
4 changes: 1 addition & 3 deletions databricks/Havvarsel - Ingest as Bronze.py
Original file line number Diff line number Diff line change
Expand Up @@ -23,10 +23,9 @@ def fetch_ocean_temperature_preditions(depth_index, lat, lon):
# COMMAND ----------

import requests
from pyspark.sql.functions import lit
from pyspark.sql.functions import lit, current_timestamp
from datetime import datetime
from helpers.adls_utils import save_df_as_delta, get_adls_folder_path, connect_to_adls

connect_to_adls()

fetch_time = current_timestamp()
Expand All @@ -38,7 +37,6 @@ def fetch_ocean_temperature_preditions(depth_index, lat, lon):

# COMMAND ----------

from pyspark.sql.functions import unix_timestamp, current_timestamp

for loc_nr, location in enumerate(locations):
for depth_index in depth_indices:
Expand Down

0 comments on commit 26adaad

Please sign in to comment.