diff --git a/cli.py b/cli.py index e1ea466..8b9b9a9 100644 --- a/cli.py +++ b/cli.py @@ -175,8 +175,10 @@ def enqueue_s3_export(block_number: int): logger.info(f"Sending block {block_number} export to queue") export_actor.send(block_number) + @cli.command() -@click.argument("block_number", type=int) +@click.argument("after_block", type=int) +@click.argument("before_block", type=int) def enqueue_many_s3_exports(after_block: int, before_block: int): broker = connect_broker() export_actor = dramatiq.actor(export_block_task, broker=broker) diff --git a/mev b/mev index 8469268..2fa0a06 100755 --- a/mev +++ b/mev @@ -98,6 +98,13 @@ case "$1" in exit 1 esac ;; + backfill-export) + after_block=$2 + before_block=$3 + + echo "Sending $block_number export to queue" + kubectl exec -ti deploy/mev-inspect -- poetry run enqueue-many-s3-exports $after_block $before_block + ;; enqueue-s3-export) block_number=$2 diff --git a/pyproject.toml b/pyproject.toml index 0c5892f..c8d050b 100644 --- a/pyproject.toml +++ b/pyproject.toml @@ -44,6 +44,7 @@ fetch-all-prices = 'cli:fetch_all_prices' fetch-range = 'cli:fetch_range' s3-export = 'cli:s3_export' enqueue-s3-export = 'cli:enqueue_s3_export' +backfill-export = 'cli:enqueue_many_s3_exports' [tool.black] exclude = '''