|
7 | 7 |
|
8 | 8 | import datetime |
9 | 9 | import uuid |
10 | | -from dateutil.tz import tzutc |
| 10 | +from datetime import timezone |
11 | 11 | import pytest |
12 | 12 | import functools |
13 | 13 | from azure.core.exceptions import ResourceNotFoundError |
@@ -70,7 +70,7 @@ async def test_create_simple_data_feed(self, client, variables): |
70 | 70 | assert data_feed.granularity.granularity_type == "Daily" |
71 | 71 | assert data_feed.schema.metrics[0].name == "cost" |
72 | 72 | assert data_feed.schema.metrics[1].name == "revenue" |
73 | | - assert data_feed.ingestion_settings.ingestion_begin_time == datetime.datetime(2019, 10, 1, tzinfo=tzutc()) |
| 73 | + assert data_feed.ingestion_settings.ingestion_begin_time == datetime.datetime(2019, 10, 1, tzinfo=timezone.utc) |
74 | 74 |
|
75 | 75 | finally: |
76 | 76 | await self.clean_up(client.delete_data_feed, variables) |
@@ -146,7 +146,7 @@ async def test_create_data_feed_from_sql_server(self, client, variables): |
146 | 146 | assert data_feed.schema.dimensions[1].name == "city" |
147 | 147 | assert data_feed.schema.dimensions[0].display_name == "display category" |
148 | 148 | assert data_feed.schema.dimensions[1].display_name == "display city" |
149 | | - assert data_feed.ingestion_settings.ingestion_begin_time == datetime.datetime(2019, 10, 1, tzinfo=tzutc()) |
| 149 | + assert data_feed.ingestion_settings.ingestion_begin_time == datetime.datetime(2019, 10, 1, tzinfo=timezone.utc) |
150 | 150 | assert data_feed.ingestion_settings.data_source_request_concurrency == 0 |
151 | 151 | assert data_feed.ingestion_settings.ingestion_retry_delay == -1 |
152 | 152 | assert data_feed.ingestion_settings.ingestion_start_offset == -1 |
@@ -243,7 +243,7 @@ async def test_create_data_feed_from_sql_server_with_custom_values(self, client, |
243 | 243 | assert data_feed.schema.dimensions[1].name == "city" |
244 | 244 | assert data_feed.schema.dimensions[0].display_name == "display category" |
245 | 245 | assert data_feed.schema.dimensions[1].display_name == "display city" |
246 | | - assert data_feed.ingestion_settings.ingestion_begin_time == datetime.datetime(2019, 10, 1, tzinfo=tzutc()) |
| 246 | + assert data_feed.ingestion_settings.ingestion_begin_time == datetime.datetime(2019, 10, 1, tzinfo=timezone.utc) |
247 | 247 | assert data_feed.ingestion_settings.data_source_request_concurrency == 0 |
248 | 248 | assert data_feed.ingestion_settings.ingestion_retry_delay == -1 |
249 | 249 | assert data_feed.ingestion_settings.ingestion_start_offset == -1 |
@@ -861,7 +861,7 @@ async def test_update_data_feed_with_model(self, client, variables): |
861 | 861 | assert updated.name == variables["data_feed_updated_name"] |
862 | 862 | assert updated.data_feed_description == "updated" |
863 | 863 | assert updated.schema.timestamp_column == "time" |
864 | | - assert updated.ingestion_settings.ingestion_begin_time == datetime.datetime(2021, 12, 10, tzinfo=tzutc()) |
| 864 | + assert updated.ingestion_settings.ingestion_begin_time == datetime.datetime(2021, 12, 10, tzinfo=timezone.utc) |
865 | 865 | assert updated.ingestion_settings.ingestion_start_offset == 1 |
866 | 866 | assert updated.ingestion_settings.data_source_request_concurrency == 1 |
867 | 867 | assert updated.ingestion_settings.ingestion_retry_delay == 120 |
@@ -920,7 +920,7 @@ async def test_update_data_feed_with_kwargs(self, client, variables): |
920 | 920 | assert updated.name == variables["data_feed_updated_name"] |
921 | 921 | assert updated.data_feed_description == "updated" |
922 | 922 | assert updated.schema.timestamp_column == "time" |
923 | | - assert updated.ingestion_settings.ingestion_begin_time == datetime.datetime(2021, 9, 10, tzinfo=tzutc()) |
| 923 | + assert updated.ingestion_settings.ingestion_begin_time == datetime.datetime(2021, 9, 10, tzinfo=timezone.utc) |
924 | 924 | assert updated.ingestion_settings.ingestion_start_offset == 1 |
925 | 925 | assert updated.ingestion_settings.data_source_request_concurrency == 1 |
926 | 926 | assert updated.ingestion_settings.ingestion_retry_delay == 120 |
@@ -998,7 +998,7 @@ async def test_update_data_feed_with_model_and_kwargs(self, client, variables): |
998 | 998 | assert updated.name == variables["data_feed_updated_name"] |
999 | 999 | assert updated.data_feed_description == "updateMe" |
1000 | 1000 | assert updated.schema.timestamp_column == "time" |
1001 | | - assert updated.ingestion_settings.ingestion_begin_time == datetime.datetime(2021, 9, 10, tzinfo=tzutc()) |
| 1001 | + assert updated.ingestion_settings.ingestion_begin_time == datetime.datetime(2021, 9, 10, tzinfo=timezone.utc) |
1002 | 1002 | assert updated.ingestion_settings.ingestion_start_offset == 1 |
1003 | 1003 | assert updated.ingestion_settings.data_source_request_concurrency == 1 |
1004 | 1004 | assert updated.ingestion_settings.ingestion_retry_delay == 120 |
@@ -1053,7 +1053,7 @@ async def test_update_data_feed_by_reseting_properties(self, client, variables): |
1053 | 1053 | assert updated.name == variables["data_feed_updated_name"] |
1054 | 1054 | # assert updated.data_feed_description == "" # doesn't currently clear |
1055 | 1055 | # assert updated.schema.timestamp_column == "" # doesn't currently clear |
1056 | | - assert updated.ingestion_settings.ingestion_begin_time == datetime.datetime(2019, 10, 1, tzinfo=tzutc()) |
| 1056 | + assert updated.ingestion_settings.ingestion_begin_time == datetime.datetime(2019, 10, 1, tzinfo=timezone.utc) |
1057 | 1057 | assert updated.ingestion_settings.ingestion_start_offset == -1 |
1058 | 1058 | assert updated.ingestion_settings.data_source_request_concurrency == 0 |
1059 | 1059 | assert updated.ingestion_settings.ingestion_retry_delay == -1 |
|
0 commit comments