Add bash script

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)

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
 

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 = '''