Method cb

tests/test_pipeline_files.py:91–93

()

        parent_persist_file = super().persist_file

        def cb():
            parent_persist_file(path, buf, info, meta=meta, headers=headers)
            deferred.callback(None)

        call_later(0.5, cb)
        return deferred