File tree Expand file tree Collapse file tree 2 files changed +4
-2
lines changed
execution_strategy/engine Expand file tree Collapse file tree 2 files changed +4
-2
lines changed Original file line number Diff line number Diff line change @@ -47,9 +47,11 @@ def get_time_version_data(
4747 version_number : int = None ,
4848 timestamp : datetime = None ,
4949 ):
50+ split_db_name = delta_table_name .split ('.' )
51+
5052 # Get the Delta table path
5153 delta_table_path = (
52- self .managed_table_location + delta_table_name
54+ f" { self .managed_table_location } / { split_db_name [ 0 ]. lower () } .db/ { split_db_name [ 1 ] } "
5355 if self .managed_table_location
5456 else self ._get_delta_table_path (delta_table_name )
5557 )
Original file line number Diff line number Diff line change @@ -1050,7 +1050,7 @@ def as_of(
10501050 """
10511051 self .check_resource_materialization ()
10521052
1053- validate_delta_format_parameters (timestamp , version_number )
1053+ # validate_delta_format_parameters(timestamp, version_number)
10541054 target_table = self .target_delta_table ()
10551055
10561056 return self .spark_engine .get_time_version_data (
You can’t perform that action at this time.
0 commit comments