async def METHOD_NAME(self, client, storage_cs):
    ds_name = "create"
    data_source_connection = self._create_data_source_connection(storage_cs, ds_name)
    result = await client.create_data_source_connection(data_source_connection)
    assert result.name == ds_name
    assert result.type == "azureblob"