Add --pool-size arg to start command

src/commands/create_keys.py

@@ -49,7 +49,7 @@
 @click.option(
     '--pool-size',
     help='Number of processes in a pool.',
-    # do not prompt
+    envvar='POOL_SIZE',
     type=int,
 )
 @click.command(help='Creates the validator keys from the mnemonic.')

src/commands/start.py

@@ -197,6 +197,12 @@
     envvar='LOG_LEVEL',
     help='The log level.',
 )
+@click.option(
+    '--pool-size',
+    help='Number of processes in a pool.',
+    envvar='POOL_SIZE',
+    type=int,
+)
 @click.command(help='Start operator service')
 # pylint: disable-next=too-many-arguments,too-many-locals
 def start(
@@ -223,6 +229,7 @@ def start(
     hot_wallet_password_file: str | None,
     max_fee_per_gas_gwei: int,
     database_dir: str | None,
+    pool_size: int | None,
 ) -> None:
     vault_config = VaultConfig(vault, Path(data_dir))
     if network is None:
@@ -253,6 +260,7 @@ def start(
         database_dir=database_dir,
         log_level=log_level,
         log_format=log_format,
+        pool_size=pool_size,
     )
 
     try:

src/config/settings.py

@@ -90,6 +90,7 @@ def set(
         database_dir: str | None = None,
         log_level: str | None = None,
         log_format: str | None = None,
+        pool_size: int | None = None,
     ) -> None:
         self.vault = Web3.to_checksum_address(vault)
         vault_dir.mkdir(parents=True, exist_ok=True)
@@ -168,9 +169,7 @@ def set(
         self.validators_fetch_chunk_size = decouple_config(
             'VALIDATORS_FETCH_CHUNK_SIZE', default=100, cast=int
         )
-        self.pool_size = decouple_config(
-            'POOL_SIZE', default=None, cast=lambda x: int(x) if x else None
-        )
+        self.pool_size = pool_size
         self.execution_timeout = decouple_config('EXECUTION_TIMEOUT', default=30, cast=int)
         self.execution_transaction_timeout = decouple_config(
             'EXECUTION_TRANSACTION_TIMEOUT', default=300, cast=int

src/exits/tasks.py

@@ -29,8 +29,6 @@
 
 
 class ExitSignatureTask(BaseTask):
-    keystore: BaseKeystore
-
     def __init__(self, keystore: BaseKeystore):
         self.keystore = keystore
 

src/validators/tasks.py

@@ -42,9 +42,6 @@
 
 
 class ValidatorsTask(BaseTask):
-    keystore: BaseKeystore
-    deposit_data: DepositData
-
     def __init__(
         self,
         keystore: BaseKeystore,