def METHOD_NAME(self, context):
    assert LITTLEPAY_RAW_BUCKET is not None and LITTLEPAY_PARSED_BUCKET is not None
    fs = get_fs()
    # TODO: this could be worth splitting into separate tasks
    entities = [
        "authorisations",
        "customer-funding-source",
        "device-transaction-purchases",
        "device-transactions",
        "micropayment-adjustments",
        "micropayment-device-transactions",
        "micropayments",
        "product-data",
        "refunds",
        "settlements",
    ]
    with logging_redirect_tqdm():
        for entity in tqdm(entities):
            files_to_process: List[RawLittlepayFileExtract]
            # This is not very efficient but it should be approximately 1 file per day
            # since the instance began
            files_to_process, _, _ = fetch_all_in_partition(
                cls=RawLittlepayFileExtract,
                table=entity,
                partitions={
                    "instance": self.instance,
                },
                verbose=True,
            )
            print(f"found {len(files_to_process)} files to check")
            # subtract 30 minutes because we run 30 minutes past the hour
            # in case of late-arriving data
            period = context["data_interval_end"].subtract(
                minutes=30, microseconds=1
            ) - context["data_interval_start"].subtract(minutes=30)
            print(f"filtering files created in {period}")
            files_to_process = [
                file for file in files_to_process if file.ts in period
            ]
            file: RawLittlepayFileExtract
            for file in tqdm(files_to_process, desc=entity):
                parse_raw_file(file, fs=fs)