refresh_manager.py 文件源码

def _init_global_state(self):
        if self.options.database is None:
            raise ValueError("--database is required to be defined")
        self.cluster = self.options.cluster
        self.database = self.options.database
        self.namespace = DBSourcedNamespace(
            cluster=self.cluster,
            database=self.database
        ).get_name()
        self.config_path = self.options.config_path
        self.dry_run = self.options.dry_run
        self.per_source_throughput_cap = self.options.per_source_throughput_cap
        self.total_throughput_cap = self.options.total_throughput_cap
        load_package_config(self.config_path)
        self.refresh_runner_path = self.get_refresh_runner_path()
        # Removing the cmd line arguments to prevent child process error.
        sys.argv = sys.argv[:1]