From 26adaad94c94042451c3d85d76554b9cb96198af Mon Sep 17 00:00:00 2001 From: pbullhove Date: Thu, 3 Oct 2024 13:04:48 +0000 Subject: [PATCH] fix(databricks): import method before use --- databricks/Havvarsel - Ingest as Bronze.py | 4 +--- 1 file changed, 1 insertion(+), 3 deletions(-) diff --git a/databricks/Havvarsel - Ingest as Bronze.py b/databricks/Havvarsel - Ingest as Bronze.py index 7c5b866..2039cdb 100644 --- a/databricks/Havvarsel - Ingest as Bronze.py +++ b/databricks/Havvarsel - Ingest as Bronze.py @@ -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() @@ -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: