| 104 | |
| 105 | |
| 106 | class ExtractSubmitScriptPath(CommandHandler): |
| 107 | def __init__(self, adapter: ManagerAdapter): |
| 108 | super().__init__(adapter) |
| 109 | self.queue = CommQueue() |
| 110 | |
| 111 | async def handle_cli_submit(self, input: CommandInput): |
| 112 | script_path = input.arguments[0] |
| 113 | self.queue.put(script_path) |
| 114 | return await super().handle_cli_submit(input) |
| 115 | |
| 116 | def get_script_path(self) -> str: |
| 117 | return self.queue.get() |
| 118 | |
| 119 | |
| 120 | def pause_queue(hq_env: HqEnv, queue_id: int, **kwargs): |
no outgoing calls