def METHOD_NAME(
    self,
    *args,
    endpoint_id: t.Optional[uuid.UUID] = None,
    run_dir: t.Optional[str] = None,
    results_passthrough: t.Optional[queue.Queue] = None,
    **kwargs,
):
    assert run_dir, "GCExecutor requires kwarg:run_dir at start"
    assert endpoint_id, "GCExecutor requires kwarg:endpoint_id at start"
    self.run_dir = os.path.join(os.getcwd(), run_dir)
    self.endpoint_id = endpoint_id
    script_dir = os.path.join(self.run_dir, "submit_scripts")
    self.executor.provider.script_dir = script_dir
    if (
        self.executor.provider.channel
        and not self.executor.provider.channel.script_dir
    ):
        self.executor.provider.channel.script_dir = script_dir
    os.makedirs(self.executor.provider.script_dir, exist_ok=True)
    if results_passthrough:
        # Only update the default queue in GCExecutorBase if
        # a queue is passed in
        self.results_passthrough = results_passthrough
    self.executor.METHOD_NAME()
    if self.strategy:
        self.strategy.METHOD_NAME(self)
    self._status_report_thread.METHOD_NAME()