test-issue-7102

[sgomezvillamor]

No description provided.

[codecov]

❌ 1 Tests Failed:

Tests completed	Failed	Passed	Skipped
2950	1	2949	49

View the full list of 1 ❄️ flaky tests

tests.audit_events.audit_events_test::test_policy_events

Flake rate in main: 75.00% (Passed 3 times, Failed 9 times)

Stack Traces | 31.3s run time

auth_exclude_filter = {'condition': 'EQUAL', 'field': 'name', 'negated': True, 'values': ['Test Session Token']}

    def test_policy_events(auth_exclude_filter):
        user_session = login_as(admin_user, admin_pass)
        json = {
            "query": """mutation createPolicy($input: PolicyUpdateInput!) {\n
                createPolicy(input: $input) }""",
            "variables": {
                "input": {
                    "type": "METADATA",
                    "name": "Test Metadata Policy",
                    "description": "My Metadaata Policy",
                    "state": "ACTIVE",
                    "resources": {"type": "dataset", "allResources": True},
                    "privileges": ["EDIT_ENTITY_TAGS"],
                    "actors": {
                        "users": ["urn:li:corpuser:datahub", "urn:li:corpuser:admin"],
                        "resourceOwners": False,
                        "allUsers": False,
                        "allGroups": False,
                    },
                }
            },
        }
    
        response = user_session.post(f"{get_frontend_url()}....../api/v2/graphql", json=json)
        response.raise_for_status()
        res_data = response.json()
    
        assert res_data
        assert res_data["data"]
        assert res_data["data"]["createPolicy"]
    
        wait_for_writes_to_sync(consumer_group="datahub-usage-event-consumer-job-client")
    
        new_urn = res_data["data"]["createPolicy"]
    
        update_json = {
            "query": """mutation updatePolicy($urn: String!, $input: PolicyUpdateInput!) {\n
                updatePolicy(urn: $urn, input: $input) }""",
            "variables": {
                "urn": new_urn,
                "input": {
                    "type": "METADATA",
                    "state": "ACTIVE",
                    "name": "Test Metadata Policy",
                    "description": "Updated Metadaata Policy",
                    "privileges": ["EDIT_ENTITY_TAGS", "EDIT_ENTITY_GLOSSARY_TERMS"],
                    "actors": {
                        "resourceOwners": False,
                        "allUsers": True,
                        "allGroups": False,
                    },
                },
            },
        }
    
        response = user_session.post(
            f"{get_frontend_url()}....../api/v2/graphql", json=update_json
        )
        response.raise_for_status()
        res_data = response.json()
    
        # Check updated was submitted successfully
        assert res_data
        assert res_data["data"]
        assert res_data["data"]["updatePolicy"]
        assert res_data["data"]["updatePolicy"] == new_urn
    
        wait_for_writes_to_sync(consumer_group="datahub-usage-event-consumer-job-client")
        res_data = searchForAuditEvents(
            user_session,
            3,
            ["CreatePolicyEvent", "UpdatePolicyEvent"],
            ["urn:li:corpuser:datahub", "urn:li:corpuser:admin"],
            [],
        )
        print(res_data)
        assert res_data
        assert res_data["usageEvents"]
        assert len(res_data["usageEvents"]) == 3 or len(res_data["usageEvents"]) == 2
        assert (
            res_data["usageEvents"][0]["eventType"] == "CreatePolicyEvent"
            or res_data["usageEvents"][0]["eventType"] == "UpdatePolicyEvent"
        )
        assert res_data["usageEvents"][0]["entityUrn"] == new_urn
        assert (
            res_data["usageEvents"][1]["eventType"] == "CreatePolicyEvent"
            or res_data["usageEvents"][1]["eventType"] == "UpdatePolicyEvent"
        )
        assert res_data["usageEvents"][1]["entityUrn"] == new_urn
        if len(res_data["usageEvents"]) == 3:
            assert (
                res_data["usageEvents"][2]["eventType"] == "CreatePolicyEvent"
                or res_data["usageEvents"][2]["eventType"] == "UpdatePolicyEvent"
            )
>           assert res_data["usageEvents"][2]["entityUrn"] == new_urn
E           AssertionError: assert 'urn:li:dataHubPolicy:6882d8a6-7bae-4e78-b008-6a67d13bcbfd' == 'urn:li:dataHubPolicy:fa15c228-ecad-4bb2-a525-386b9591a30c'
E             
E             - urn:li:dataHubPolicy:fa15c228-ecad-4bb2-a525-386b9591a30c
E             + urn:li:dataHubPolicy:6882d8a6-7bae-4e78-b008-6a67d13bcbfd

tests/audit_events/audit_events_test.py:333: AssertionError

To view more test analytics, go to the Test Analytics Dashboard
_{📋 Got 3 mins? Take this short survey to help us improve Test Analytics.}