From 5d36c0afadd21cf7479d58be51090d8dfebaccb0 Mon Sep 17 00:00:00 2001 From: Aseem Bansal Date: Wed, 4 Jan 2023 15:41:14 +0530 Subject: [PATCH 1/3] fix(ci): managed ingestion test fix --- smoke-test/tests/managed-ingestion/managed_ingestion_test.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/smoke-test/tests/managed-ingestion/managed_ingestion_test.py b/smoke-test/tests/managed-ingestion/managed_ingestion_test.py index d80b56b8cfcfb..aa632fe51d070 100644 --- a/smoke-test/tests/managed-ingestion/managed_ingestion_test.py +++ b/smoke-test/tests/managed-ingestion/managed_ingestion_test.py @@ -160,7 +160,7 @@ def _ensure_ingestion_source_present( if num_execs is not None: ingestion_source = res_data["data"]["ingestionSource"] - assert ingestion_source["executions"]["total"] > num_execs + assert ingestion_source["executions"]["total"] = num_execs return res_data @@ -327,7 +327,7 @@ def test_create_list_get_remove_ingestion_source(frontend_session): "name": "My Test Ingestion Source", "type": "mysql", "description": "My ingestion source description", - "schedule": {"interval": "*/5 * * * *", "timezone": "UTC"}, + "schedule": {"interval": "*/60 * * * *", "timezone": "UTC"}, "config": { "recipe": '{"source":{"type":"mysql","config":{"include_tables":true,"database":null,"password":"${MYSQL_PASSWORD}","profiling":{"enabled":false},"host_port":null,"include_views":true,"username":"${MYSQL_USERNAME}"}},"pipeline_name":"urn:li:dataHubIngestionSource:f38bd060-4ea8-459c-8f24-a773286a2927"}', "version": "0.8.18", From 2fac55844c4a87cde19c21483af2dec7267611c5 Mon Sep 17 00:00:00 2001 From: Aseem Bansal Date: Wed, 4 Jan 2023 16:30:17 +0530 Subject: [PATCH 2/3] fix sytax error --- smoke-test/tests/managed-ingestion/managed_ingestion_test.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/smoke-test/tests/managed-ingestion/managed_ingestion_test.py b/smoke-test/tests/managed-ingestion/managed_ingestion_test.py index aa632fe51d070..6a5fa861f1d67 100644 --- a/smoke-test/tests/managed-ingestion/managed_ingestion_test.py +++ b/smoke-test/tests/managed-ingestion/managed_ingestion_test.py @@ -160,7 +160,7 @@ def _ensure_ingestion_source_present( if num_execs is not None: ingestion_source = res_data["data"]["ingestionSource"] - assert ingestion_source["executions"]["total"] = num_execs + assert ingestion_source["executions"]["total"] == num_execs return res_data From 29e4e1f249a58feaa393e3653492c18ede55d851 Mon Sep 17 00:00:00 2001 From: Aseem Bansal Date: Wed, 4 Jan 2023 17:28:44 +0530 Subject: [PATCH 3/3] fix missing case --- smoke-test/tests/managed-ingestion/managed_ingestion_test.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/smoke-test/tests/managed-ingestion/managed_ingestion_test.py b/smoke-test/tests/managed-ingestion/managed_ingestion_test.py index 6a5fa861f1d67..f172e90469dcf 100644 --- a/smoke-test/tests/managed-ingestion/managed_ingestion_test.py +++ b/smoke-test/tests/managed-ingestion/managed_ingestion_test.py @@ -389,7 +389,7 @@ def test_create_list_get_remove_ingestion_source(frontend_session): assert ingestion_source["urn"] == ingestion_source_urn assert ingestion_source["type"] == "mysql" assert ingestion_source["name"] == "My Test Ingestion Source" - assert ingestion_source["schedule"]["interval"] == "*/5 * * * *" + assert ingestion_source["schedule"]["interval"] == "*/60 * * * *" assert ingestion_source["schedule"]["timezone"] == "UTC" assert ( ingestion_source["config"]["recipe"]