e5c681cba6344d361ab50b4e5d0517d871d5e3ab,tests/integration_tests/flows/test_clickhouse.py,ClickhouseTest,setUpClass,#Any#,95

Before Change

            test_csv_path,
            lines_count=100,
            rewrite=True,
            column_names=[x[0] for x in DATASETS_COLUMN_TYPES[TEST_DATASET]]
        )
        datastore.save_datasource(EXTERNAL_DS_NAME, "file", "test.csv", short_csv_file_path)

After Change

        if ds is not None:
            datastore.delete_datasource(EXTERNAL_DS_NAME)

        data = fetch(f"select * from test_data.{TEST_DATA_TABLE} limit 50", as_dict=True)
        external_datasource_csv = make_test_csv(EXTERNAL_DS_NAME, data)
        datastore.save_datasource(EXTERNAL_DS_NAME, "file", "test.csv", external_datasource_csv)

    def test_1_initial_state(self):
        print(f"\nExecuting {inspect.stack()[0].function}")

Instances