@@ -252,7 +252,7 @@ def test_construct_query_object(self, mocker, backend_fixtures):
252
252
"right_filter" : None ,
253
253
},
254
254
},
255
- "connectors" : {"test.fg_test_1" : {"type " : "hudi" }},
255
+ "connectors" : {"test.fg_test_1" : {"time_travel_type " : "hudi" }},
256
256
}
257
257
258
258
query_object ["features" ] = {
@@ -293,7 +293,7 @@ def test_construct_query_object_datetime_filter(self, mocker, backend_fixtures):
293
293
},
294
294
"right_filter" : None ,
295
295
},
296
- "connectors" : {"test.fg_test_1" : {"type " : "hudi" }},
296
+ "connectors" : {"test.fg_test_1" : {"time_travel_type " : "hudi" }},
297
297
}
298
298
299
299
query_object ["features" ] = {
@@ -331,7 +331,7 @@ def test_construct_query_object_without_fs(self, mocker, backend_fixtures):
331
331
},
332
332
"right_filter" : None ,
333
333
},
334
- "connectors" : {"test.fg_test_1" : {"type " : "hudi" }},
334
+ "connectors" : {"test.fg_test_1" : {"time_travel_type " : "hudi" }},
335
335
}
336
336
337
337
query_object ["features" ] = {
@@ -369,7 +369,7 @@ def test_construct_query_object_without_fs_excluded(self, mocker, backend_fixtur
369
369
},
370
370
"right_filter" : None ,
371
371
},
372
- "connectors" : {"test.fg_test_1" : {"type " : "hudi" }},
372
+ "connectors" : {"test.fg_test_1" : {"time_travel_type " : "hudi" }},
373
373
}
374
374
375
375
query_object ["features" ] = {
@@ -430,7 +430,8 @@ def test_construct_query_object_snowflake(self, mocker, backend_fixtures):
430
430
},
431
431
"connectors" : {
432
432
"test.tpch1snowflake_1" : {
433
- "type" : "SNOWFLAKE" ,
433
+ "time_travel_type" : None ,
434
+ "type" : 'SNOWFLAKE' ,
434
435
"options" : {
435
436
"user" : "test_user" ,
436
437
"account" : "test_url" ,
0 commit comments