def run_list()

in dataflux_core/performance_tests/list_and_download.py [0:0]

• 20 lines of code
• 5 McCabe index (conditional complexity)

    def run_list(self, config):
        list_start_time = time.time()
        list_result = fast_list.ListingController(
            config["num_workers"],
            config["project"],
            config["bucket"],
            prefix=config["prefix"],
        ).run()
        list_end_time = time.time()
        listing_time = list_end_time - list_start_time
        if (config["expected_file_count"]
                and len(list_result) != config["expected_file_count"]):
            raise AssertionError(
                f"Expected {config['expected_file_count']} files, but got {len(list_result)}"
            )
        if config["list_timeout"] and listing_time > config["list_timeout"]:
            raise AssertionError(
                f"Expected list operation to complete in under {config['list_timeout']} seconds, but took {listing_time} seconds."
            )
        return list_result