diff --git a/tests/activities/test_gates.py b/tests/activities/test_gates.py index ab5b0a4..dec6b9d 100644 --- a/tests/activities/test_gates.py +++ b/tests/activities/test_gates.py @@ -37,6 +37,7 @@ async def test_data_quality_gate_with_null_values_filter_discard(gates_fixture): } }, 'data': { + 'name': ['tag1', 'tag2', 'tag3'], 'tag': ['tag1', 'tag2', 'tag3'], 'value': [1.0, None, 3.0], 'timestamp': ['2023-01-01', '2023-01-02', '2023-01-03'], @@ -69,6 +70,7 @@ async def test_data_quality_gate_with_out_of_bounds_filter_keep(gates_fixture): } }, 'data': { + 'name': ['tag1', 'tag2', 'tag3'], 'tag': ['tag1', 'tag2', 'tag3'], 'value': [1.0, 200.0, 3.0], 'timestamp': ['2023-01-01', '2023-01-02', '2023-01-03'] diff --git a/tests/activities/test_redis.py b/tests/activities/test_redis.py index 99eed1f..ce3215e 100644 --- a/tests/activities/test_redis.py +++ b/tests/activities/test_redis.py @@ -164,7 +164,7 @@ async def test_put_last_data_timestamp_not_empty_dataframe(redis_activity): redis_activity.set.assert_called_once_with( 'last_data_timestamp_test_pipeline_test_schedule', '2023-01-01 12:00:01', - ttl=None + ttl=18000 )