ads.opctl.distributed package

Subpackages

• ads.opctl.distributed.common package
  • Submodules
  • ads.opctl.distributed.common.abstract_cluster_provider module
    • ClusterProvider
      • ClusterProvider.DEFAULT_CODE_DIR
      • ClusterProvider.SYNC_SCRIPT_PATH
      • ClusterProvider.basic_configuration()
      • ClusterProvider.check_cluster_status()
      • ClusterProvider.configuration()
      • ClusterProvider.create_sync_script()
      • ClusterProvider.execution_failed()
      • ClusterProvider.expected_worker_count()
      • ClusterProvider.export_config_files()
      • ClusterProvider.export_configuration()
      • ClusterProvider.fetch_all_worker_info()
      • ClusterProvider.fetch_code()
      • ClusterProvider.find_self_ip()
      • ClusterProvider.get_oci_auth()
      • ClusterProvider.get_sync_loc()
      • ClusterProvider.get_sync_script()
      • ClusterProvider.profile_cmd()
      • ClusterProvider.reached_endoflife()
      • ClusterProvider.ready()
      • ClusterProvider.run_code()
      • ClusterProvider.setup_configuration()
      • ClusterProvider.setup_extra_configs()
      • ClusterProvider.start()
      • ClusterProvider.start_main()
      • ClusterProvider.start_ps()
      • ClusterProvider.start_worker()
      • ClusterProvider.stop()
      • ClusterProvider.stop_filesystem
      • ClusterProvider.sync()
      • ClusterProvider.tearable()
      • ClusterProvider.when_ready()
  • ads.opctl.distributed.common.abstract_framework_spec_builder module
    • AbstractFrameworkSpecBuilder
      • AbstractFrameworkSpecBuilder.update()
    • update_env_vars()
  • ads.opctl.distributed.common.cluster_config_helper module
    • ClusterConfigToJobSpecConverter
      • ClusterConfigToJobSpecConverter.job_def_info()
      • ClusterConfigToJobSpecConverter.job_run_info()
  • ads.opctl.distributed.common.cluster_provider_factory module
    • ClusterProviderFactory
      • ClusterProviderFactory.get_provider()
      • ClusterProviderFactory.provider
      • ClusterProviderFactory.register()
  • ads.opctl.distributed.common.cluster_runner module
    • ClusterRunner
      • ClusterRunner.run()
  • ads.opctl.distributed.common.framework_factory module
  • Module contents

Submodules

ads.opctl.distributed.certificates module

ads.opctl.distributed.certificates.download_certificates(auth, ca_file_name, cert_file_name, key_file_name)

ads.opctl.distributed.cli module

ads.opctl.distributed.cmds module

Module contents