AssertionError: Row count expected = 0, while actual row count = 4
assert 4 == 0
self = <tests.test_e2e_ingest.TestE2E object at 0x7fb0255da660>

    @pytest.mark.asyncio
    async def test_json_ingestion_ingest_by_tag(self):
        table = await self.init_table("json_ingestion_ingest_by_tag")
        try:
            json_ingestion_props = IngestionProperties(
                self.test_db,
                table,
                data_format=DataFormat.JSON,
                column_mappings=self.table_json_mappings(),
                ingest_if_not_exists=["ingestByTag"],
                report_level=ReportLevel.FailuresAndSuccesses,
                drop_by_tags=["drop", "drop-by"],
                flush_immediately=True,
            )
    
            for f in [self.json_file_path, self.zipped_json_file_path]:
                self.ingest_client.ingest_from_file(f, json_ingestion_props)
    
>           await self.assert_rows_added(table, 0)

azure-kusto-ingest/tests/test_e2e_ingest.py:435: 
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 

cls = <class 'tests.test_e2e_ingest.TestE2E'>
table_name = 'python_test_3_12_3_1766656159_59054_json_ingestion_ingest_by_tag_1766656159_49498'
expected = 0, timeout = 119

    @classmethod
    async def assert_rows_added(cls, table_name: str, expected: int, timeout: int = 120):
        actual = 0
        while timeout > 0:
            time.sleep(1)
            timeout -= 1
    
            try:
                async with await cls.get_async_client() as async_client:
                    command = "{} | count".format(table_name)
                    response = cls.client.execute(cls.test_db, command)
                    response_from_async = await async_client.execute(cls.test_db, command)
            except KustoServiceError:
                continue
    
            if response is not None:
                row = response.primary_results[0][0]
                row_async = response_from_async.primary_results[0][0]
                actual = int(row["Count"])
                actual_async = int(row_async["Count"])
                # this is done to allow for data to arrive properly
                if actual >= expected and actual_async >= expected:
                    break
>       assert actual == expected, "Row count expected = {0}, while actual row count = {1}".format(expected, actual)
E       AssertionError: Row count expected = 0, while actual row count = 4
E       assert 4 == 0

azure-kusto-ingest/tests/test_e2e_ingest.py:261: AssertionError

AssertionError: Row count expected = 10, while actual row count = 20
assert 20 == 10
self = <tests.test_e2e_ingest.TestE2E object at 0x7f8ea2f2d190>

    @pytest.mark.asyncio
    async def test_ingest_blob(self):
        if not self.test_blob:
            pytest.skip("Provide blob SAS uri with 'dataset.csv'")
    
        table = await self.init_table("ingest_blob")
        try:
            csv_ingest_props = IngestionProperties(
                self.test_db,
                table,
                data_format=DataFormat.CSV,
                column_mappings=self.get_test_table_csv_mappings(),
                report_level=ReportLevel.FailuresAndSuccesses,
                flush_immediately=True,
            )
    
            blob_len = 1578
            self.ingest_client.ingest_from_blob(BlobDescriptor(self.test_blob, blob_len), csv_ingest_props)
    
            await self.assert_rows_added(table, 10)
    
            # Don't provide size hint
            self.ingest_client.ingest_from_blob(BlobDescriptor(self.test_blob, size=None), csv_ingest_props)
    
>           await self.assert_rows_added(table, 10)

azure-kusto-ingest/tests/test_e2e_ingest.py:482: 
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 

cls = <class 'tests.test_e2e_ingest.TestE2E'>
table_name = 'python_test_3_11_14_1766656141_30811_ingest_blob_1766656169_49913'
expected = 10, timeout = 119

    @classmethod
    async def assert_rows_added(cls, table_name: str, expected: int, timeout: int = 120):
        actual = 0
        while timeout > 0:
            time.sleep(1)
            timeout -= 1
    
            try:
                async with await cls.get_async_client() as async_client:
                    command = "{} | count".format(table_name)
                    response = cls.client.execute(cls.test_db, command)
                    response_from_async = await async_client.execute(cls.test_db, command)
            except KustoServiceError:
                continue
    
            if response is not None:
                row = response.primary_results[0][0]
                row_async = response_from_async.primary_results[0][0]
                actual = int(row["Count"])
                actual_async = int(row_async["Count"])
                # this is done to allow for data to arrive properly
                if actual >= expected and actual_async >= expected:
                    break
>       assert actual == expected, "Row count expected = {0}, while actual row count = {1}".format(expected, actual)
E       AssertionError: Row count expected = 10, while actual row count = 20
E       assert 20 == 10

azure-kusto-ingest/tests/test_e2e_ingest.py:261: AssertionError