Observatory Platform
latest
Installation
Tutorials
Observatory Platform API
License
API Reference
Observatory Platform
Index
Edit on GitHub
Index
_
|
A
|
B
|
C
|
D
|
E
|
F
|
G
|
H
|
I
|
J
|
K
|
L
|
M
|
N
|
O
|
P
|
R
|
S
|
T
|
U
|
V
|
W
|
X
|
Y
|
Z
_
__call__() (api.client.api_client.Endpoint method)
(platform.workflows.workflow.ListReleaseFunction method)
(platform.workflows.workflow.ReleaseFunction method)
__call_api() (api.client.api_client.ApiClient method)
__contains__() (api.client.model_utils.ModelComposed method)
(api.client.model_utils.ModelNormal method)
(api.client.model_utils.ModelSimple method)
__copy__() (api.client.model_utils.OpenApiModel method)
__deepcopy__() (api.client.configuration.Configuration method)
(api.client.model_utils.OpenApiModel method)
__enter__() (api.client.api_client.ApiClient method)
__eq__() (api.client.model_utils.ModelComposed method)
(api.client.model_utils.ModelNormal method)
(api.client.model_utils.ModelSimple method)
(platform.terraform.terraform_api.TerraformVariable method)
(platform.workflows.workflow.ChangefileRelease method)
__exit__() (api.client.api_client.ApiClient method)
__gather_params() (api.client.api_client.Endpoint method)
__get__() (api.client.model_utils.cached_property method)
__getattr__() (api.client.model_utils.OpenApiModel method)
__getitem__() (api.client.model_utils.ModelComposed method)
(api.client.model_utils.ModelNormal method)
(api.client.model_utils.ModelSimple method)
__hash__() (platform.terraform.terraform_api.TerraformVariable method)
__ne__() (api.client.model_utils.OpenApiModel method)
__repr__() (api.client.model_utils.OpenApiModel method)
__run_docker_compose_cmd() (platform.docker.compose_runner.ComposeRunner method)
__setattr__() (api.client.configuration.Configuration method)
(api.client.model_utils.OpenApiModel method)
__setitem__() (api.client.model_utils.ModelComposed method)
(api.client.model_utils.ModelNormal method)
(api.client.model_utils.ModelSimple method)
__str__() (api.client.exceptions.ApiException method)
(platform.terraform.terraform_api.TerraformVariable method)
(platform.workflows.workflow.ChangefileRelease method)
(platform.workflows.workflow.PartitionRelease method)
(platform.workflows.workflow.Release method)
(platform.workflows.workflow.SnapshotRelease method)
__tablename__ (api.server.orm.DatasetRelease attribute)
__unset_attribute_value__ (api.client.model_utils.ModelComposed attribute)
__validate_inputs() (api.client.api_client.Endpoint method)
__version__ (in module api.client)
_apply_auth_params() (api.client.api_client.ApiClient method)
_base_path (api.client.configuration.Configuration attribute)
_check_success_runs() (platform.workflows.vm_workflow.VmDestroyWorkflow method)
_composed_schemas (api.client.model.dataset_release.DatasetRelease attribute)
_create_bucket() (platform.observatory_environment.ObservatoryEnvironment method)
_create_dataset() (platform.observatory_environment.ObservatoryEnvironment method)
_default (api.client.configuration.Configuration attribute)
_delete_bucket() (platform.observatory_environment.ObservatoryEnvironment method)
_delete_dataset() (platform.observatory_environment.ObservatoryEnvironment method)
_from_openapi_data() (api.client.model.dataset_release.DatasetRelease class method)
_generate_key() (platform.observatory_environment.SftpServer method)
_get_last_execution_prev() (platform.workflows.vm_workflow.VmDestroyWorkflow method)
_is_utf8_str() (in module platform.gcs)
_new_from_openapi_data() (api.client.model_utils.OpenApiModel class method)
_nullable (api.client.model.dataset_release.DatasetRelease attribute)
_parse_fields() (platform.observatory_config.ObservatoryConfig static method)
_pool (api.client.api_client.ApiClient attribute)
_start_server() (platform.observatory_environment.SftpServer method)
_validate_google_application_credentials() (platform.observatory_config.ObservatoryConfigValidator method)
A
aborted (platform.gcs.TransferStatus attribute)
AbstractWorkflow (class in platform.workflows.workflow)
academic_observatory_workflows() (platform.cli.generate_command.DefaultWorkflowsProject static method)
add_bucket() (platform.observatory_environment.ObservatoryEnvironment method)
add_connection() (platform.observatory_environment.ObservatoryEnvironment method)
add_dataset() (platform.observatory_environment.ObservatoryEnvironment method)
add_file() (platform.docker.builder.Builder method)
(platform.docker.builder.BuilderInterface method)
add_operator() (platform.workflows.workflow.AbstractWorkflow method)
(platform.workflows.workflow.Workflow method)
add_partition_date() (in module platform.files)
add_setup_task() (platform.workflows.workflow.AbstractWorkflow method)
(platform.workflows.workflow.Workflow method)
add_task() (platform.workflows.workflow.AbstractWorkflow method)
(platform.workflows.workflow.Workflow method)
add_template() (platform.docker.builder.Builder method)
(platform.docker.builder.BuilderInterface method)
add_variable() (platform.observatory_environment.ObservatoryEnvironment method)
add_workspace_variable() (platform.terraform.terraform_api.TerraformApi method)
additional_properties_type (api.client.model.dataset_release.DatasetRelease attribute)
airflow_fernet_key (platform.observatory_config.Observatory attribute)
airflow_main_vm() (platform.observatory_config.ObserveratoryConfigString static method)
airflow_secret_key (platform.observatory_config.Observatory attribute)
airflow_ui_port (platform.observatory_config.Observatory attribute)
airflow_ui_user_email (platform.observatory_config.Observatory attribute)
airflow_ui_user_password (platform.observatory_config.Observatory attribute)
airflow_var_dags_module_names (platform.observatory_config.ObservatoryConfig property)
airflow_var_workflows (platform.observatory_config.ObservatoryConfig property)
AIRFLOW_VERSION (in module platform.docker.platform_runner)
airflow_vm_lines_() (platform.observatory_config.ObserveratoryConfigString static method)
airflow_worker_vm() (platform.observatory_config.ObserveratoryConfigString static method)
AirflowConns (class in platform.config)
AirflowVars (class in platform.config)
allowed_values (api.client.model.dataset_release.DatasetRelease attribute)
allows_single_value_input() (in module api.client.model_utils)
api
module
api.cli
module
api.client
module
api.client.api
module
api.client.api.observatory_api
module
api.client.api_client
module
api.client.configuration
module
api.client.exceptions
module
api.client.model
module
api.client.model.dataset_release
module
api.client.model_utils
module
api.client.rest
module
api.server
module
api.server.api
module
api.server.app
module
api.server.openapi_renderer
module
api.server.orm
module
api.testing
module
api.utils
module
api_package (platform.observatory_config.Observatory attribute)
api_package_type (platform.observatory_config.Observatory attribute)
api_port (platform.observatory_config.Observatory attribute)
ApiAttributeError
ApiClient (class in api.client.api_client)
ApiException
ApiKeyError
ApiTypeError
ApiValueError
app (in module api.server.app)
assert_blob_exists() (platform.observatory_environment.ObservatoryTestCase method)
assert_blob_integrity() (platform.observatory_environment.ObservatoryTestCase method)
assert_cleanup() (platform.observatory_environment.ObservatoryTestCase method)
assert_dag_load() (platform.observatory_environment.ObservatoryTestCase method)
assert_dag_load_from_config() (platform.observatory_environment.ObservatoryTestCase method)
assert_dag_structure() (platform.observatory_environment.ObservatoryTestCase method)
assert_file_integrity() (platform.observatory_environment.ObservatoryTestCase method)
assert_gcp_dependencies() (platform.observatory_environment.ObservatoryEnvironment method)
assert_hostname (api.client.configuration.Configuration attribute)
assert_table_bytes() (platform.observatory_environment.ObservatoryTestCase method)
assert_table_content() (platform.observatory_environment.ObservatoryTestCase method)
assert_table_id() (in module platform.bigquery)
assert_table_integrity() (platform.observatory_environment.ObservatoryTestCase method)
attempt_convert_item() (in module api.client.model_utils)
attribute_map (api.client.model.dataset_release.DatasetRelease attribute)
auth_settings() (api.client.configuration.Configuration method)
aws_bucket_test_env() (in module platform.observatory_environment)
B
Backend (class in platform.observatory_config)
backend() (platform.observatory_config.ObserveratoryConfigString static method)
BackendType (class in platform.observatory_config)
backup_start_time (platform.observatory_config.CloudSqlDatabase attribute)
Base (in module api.server.orm)
BIGQUERY_SINGLE_QUERY_BYTE_LIMIT (in module platform.bigquery)
BOLD (in module platform.cli.generate_command)
bq_copy_table() (in module platform.bigquery)
bq_create_dataset() (in module platform.bigquery)
bq_create_empty_table() (in module platform.bigquery)
bq_create_table_from_query() (in module platform.bigquery)
bq_create_view() (in module platform.bigquery)
bq_dataset_test_env() (in module platform.observatory_environment)
bq_delete_old_datasets_with_prefix() (in module platform.bigquery)
bq_delete_records() (in module platform.bigquery)
bq_export_table() (in module platform.bigquery)
bq_find_schema() (in module platform.bigquery)
bq_get_table() (in module platform.bigquery)
bq_list_datasets_with_prefix() (in module platform.bigquery)
bq_list_tables() (in module platform.bigquery)
bq_load_from_memory() (in module platform.bigquery)
bq_load_table() (in module platform.bigquery)
bq_load_tables() (in module platform.observatory_environment)
bq_query_bytes_budget_check() (in module platform.bigquery)
bq_query_bytes_estimate() (in module platform.bigquery)
bq_run_query() (in module platform.bigquery)
bq_select_columns() (in module platform.bigquery)
bq_select_latest_table() (in module platform.bigquery)
bq_select_table_shard_dates() (in module platform.bigquery)
bq_sharded_table_id() (in module platform.bigquery)
bq_snapshot() (in module platform.bigquery)
bq_table_exists() (in module platform.bigquery)
bq_table_id() (in module platform.bigquery)
bq_table_id_parts() (in module platform.bigquery)
bq_table_shard_info() (in module platform.bigquery)
bq_update_table_description() (in module platform.bigquery)
bq_upsert_records() (in module platform.bigquery)
build() (platform.cli.generate_command.InteractiveConfigBuilder static method)
(platform.docker.compose_runner.ComposeRunner method)
build_image() (platform.cli.terraform_command.TerraformCommand method)
(platform.terraform.terraform_builder.TerraformBuilder method)
build_schedule() (in module platform.api)
build_terraform() (platform.cli.terraform_command.TerraformCommand method)
(platform.terraform.terraform_builder.TerraformBuilder method)
Builder (class in platform.docker.builder)
BuilderInterface (class in platform.docker.builder)
C
cached_property (class in api.client.model_utils)
call_api() (api.client.api_client.ApiClient method)
call_with_http_info() (api.client.api_client.Endpoint method)
category (platform.terraform.terraform_api.TerraformVariable attribute)
cert_file (api.client.configuration.Configuration attribute)
change_keys() (in module platform.files)
change_keys_js_to_python() (in module api.client.model_utils)
change_task_log_level() (in module platform.airflow)
changefile_end_date (api.server.orm.DatasetRelease attribute)
,
[1]
changefile_start_date (api.server.orm.DatasetRelease attribute)
,
[1]
ChangefileRelease (class in platform.workflows.workflow)
check_allowed_values() (in module api.client.model_utils)
check_connections() (in module platform.airflow)
(in module platform.refactor.tasks)
check_dag_exists() (platform.utils.dag_run_sensor.DagRunSensor method)
check_dags_status() (platform.workflows.vm_workflow.VmDestroyWorkflow method)
check_dependencies() (in module platform.refactor.tasks)
(platform.workflows.workflow.Workflow method)
check_run_status() (platform.workflows.vm_workflow.VmCreateWorkflow method)
(platform.workflows.vm_workflow.VmDestroyWorkflow method)
check_runtime_vm() (platform.workflows.vm_workflow.VmDestroyWorkflow method)
check_schema_field_fernet_key() (in module platform.observatory_config)
check_schema_field_secret_key() (in module platform.observatory_config)
check_terraform_run_status() (platform.workflows.vm_workflow.TerraformVirtualMachineAPI method)
check_validations() (in module api.client.model_utils)
check_variables() (in module platform.airflow)
(in module platform.refactor.tasks)
check_vm_state() (platform.workflows.vm_workflow.VmCreateWorkflow method)
(platform.workflows.vm_workflow.VmDestroyWorkflow method)
check_workflow_inputs() (in module platform.workflows.workflow)
class_name (platform.observatory_config.Workflow attribute)
(platform.refactor.workflow.Workflow attribute)
clean_dir() (in module platform.files)
cleanup() (in module platform.refactor.workflow)
(in module platform.workflows.workflow)
(platform.workflows.vm_workflow.VmCreateWorkflow method)
(platform.workflows.vm_workflow.VmDestroyWorkflow method)
cli() (in module api.cli)
(in module platform.cli.cli)
close() (api.client.api_client.ApiClient method)
cloud_sql_database() (platform.observatory_config.ObserveratoryConfigString static method)
cloud_workspace (platform.observatory_config.Workflow attribute)
(platform.observatory_environment.ObservatoryEnvironment property)
(platform.refactor.workflow.Workflow attribute)
CloudSqlDatabase (class in platform.observatory_config)
CloudStorageBucket (class in platform.observatory_config)
CloudWorkspace (class in platform.observatory_config)
(class in platform.refactor.workflow)
COERCIBLE_TYPE_PAIRS (in module api.client.model_utils)
COERCION_INDEX_BY_TYPE (in module api.client.model_utils)
comment() (in module platform.cli.cli_utils)
compare_lists_of_dicts() (in module platform.observatory_environment)
COMPOSE_ARGS_PREFIX (platform.docker.compose_runner.ComposeRunner attribute)
COMPOSE_BUILD_ARGS (platform.docker.compose_runner.ComposeRunner attribute)
compose_file_name (platform.docker.compose_runner.ComposeRunner property)
COMPOSE_START_ARGS (platform.docker.compose_runner.ComposeRunner attribute)
COMPOSE_STOP_ARGS (platform.docker.compose_runner.ComposeRunner attribute)
composed_model_input_classes() (in module api.client.model_utils)
ComposeRunner (class in platform.docker.compose_runner)
compress_chunk() (in module platform.files)
Config (in module platform.observatory_config)
config() (in module platform.cli.cli)
config_airflow_main_vm() (platform.cli.generate_command.InteractiveConfigBuilder static method)
config_airflow_worker_vm() (platform.cli.generate_command.InteractiveConfigBuilder static method)
config_backend() (platform.cli.generate_command.InteractiveConfigBuilder static method)
config_cloud_sql_database() (platform.cli.generate_command.InteractiveConfigBuilder static method)
config_google_cloud() (platform.cli.generate_command.InteractiveConfigBuilder static method)
config_observatory() (platform.cli.generate_command.InteractiveConfigBuilder static method)
config_terraform() (platform.cli.generate_command.InteractiveConfigBuilder static method)
config_workflows_projects() (platform.cli.generate_command.InteractiveConfigBuilder static method)
Configuration (class in api.client.configuration)
connection_pool_maxsize (api.client.configuration.Configuration attribute)
convert() (in module platform.files)
(platform.cli.generate_command.FernetKeyType method)
(platform.cli.generate_command.FlaskSecretKeyType method)
convert_js_args_to_python_args() (in module api.client.model_utils)
copy_dir() (in module platform.terraform.terraform_builder)
crc32c_base64_hash() (in module platform.files)
create (platform.observatory_config.VirtualMachine attribute)
create() (api.testing.ObservatoryApiEnvironment method)
(platform.observatory_environment.FtpServer method)
(platform.observatory_environment.HttpServer method)
(platform.observatory_environment.ObservatoryEnvironment method)
(platform.observatory_environment.SftpServer method)
create_app() (in module api.server.api)
create_configuration_version() (platform.terraform.terraform_api.TerraformApi method)
create_dag_run() (platform.observatory_environment.ObservatoryEnvironment method)
create_gcp_env (platform.observatory_environment.ObservatoryEnvironment property)
create_run() (platform.terraform.terraform_api.TerraformApi method)
create_session() (in module api.server.orm)
create_terraform_run() (platform.workflows.vm_workflow.TerraformVirtualMachineAPI method)
create_workspace() (platform.cli.terraform_command.TerraformCommand method)
(platform.terraform.terraform_api.TerraformApi method)
created (api.server.orm.DatasetRelease attribute)
,
[1]
credentials (platform.observatory_config.GoogleCloud attribute)
customise_pointer() (in module platform.observatory_config)
D
dag_id (api.server.orm.DatasetRelease attribute)
,
[1]
(platform.observatory_config.Workflow attribute)
(platform.refactor.workflow.Workflow attribute)
dag_run_id (api.server.orm.DatasetRelease attribute)
,
[1]
DagCompleteSensor (class in platform.refactor.sensors)
DagRunSensor (class in platform.utils.dag_run_sensor)
dags_module (platform.observatory_config.WorkflowsProject attribute)
DAGS_MODULE_NAMES (platform.config.AirflowVars attribute)
dags_modules (in module platform.dags.load_dags_modules)
dags_path (in module platform.dags.load_dags_modules)
data_interval_end (api.server.orm.DatasetRelease attribute)
,
[1]
data_interval_start (api.server.orm.DatasetRelease attribute)
,
[1]
data_location (platform.observatory_config.CloudWorkspace property)
(platform.observatory_config.GoogleCloud attribute)
(platform.refactor.workflow.CloudWorkspace property)
DATA_PATH (platform.config.AirflowVars attribute)
dataset_id (api.server.orm.DatasetRelease attribute)
,
[1]
(platform.observatory_environment.Table attribute)
DatasetRelease (class in api.client.model.dataset_release)
(class in api.server.orm)
DATE_TIME_FORMAT (in module platform.workflows.workflow)
debug (api.client.configuration.Configuration attribute)
(api.client.configuration.Configuration property)
DEBUG (in module platform.docker.platform_runner)
default() (platform.observatory_config.PendulumDateTimeEncoder method)
(platform.refactor.workflow.PendulumDateTimeEncoder method)
default_args (in module platform.dags.dummy_telescope)
DEFAULT_CHUNK_SIZE (in module platform.gcs)
DefaultWorkflowsProject (class in platform.cli.generate_command)
DELETE() (api.client.rest.RESTClientObject method)
delete_dataset_release() (api.client.api.observatory_api.ObservatoryApi method)
(in module api.server.api)
delete_item() (in module api.server.api)
delete_old_xcoms() (in module platform.airflow)
delete_workspace() (platform.terraform.terraform_api.TerraformApi method)
delete_workspace_variable() (platform.terraform.terraform_api.TerraformApi method)
description (platform.terraform.terraform_api.TerraformVariable attribute)
deserialize() (api.client.api_client.ApiClient method)
deserialize_file() (in module api.client.model_utils)
deserialize_model() (in module api.client.model_utils)
deserialize_primitive() (in module api.client.model_utils)
develop (platform.observatory_config.Environment attribute)
discriminator() (api.client.model.dataset_release.DatasetRelease method)
disk_size (platform.observatory_config.VirtualMachine attribute)
disk_type (platform.observatory_config.VirtualMachine attribute)
docker_compose (platform.docker.platform_runner.PlatformRunner property)
docker_compose_project_name (platform.observatory_config.Observatory attribute)
docker_exe_path (platform.docker.platform_runner.PlatformRunner property)
docker_module_path (platform.docker.platform_runner.PlatformRunner property)
docker_network_is_external (platform.observatory_config.Observatory attribute)
docker_network_name (platform.observatory_config.Observatory attribute)
docker_package (platform.observatory_config.PythonPackage attribute)
download_bucket (platform.observatory_config.CloudWorkspace property)
(platform.refactor.workflow.CloudWorkspace property)
download_file() (in module platform.utils.http_download)
download_files() (in module platform.utils.http_download)
download_folder (platform.workflows.workflow.Release property)
download_http_file_() (in module platform.utils.http_download)
download_http_files_() (in module platform.utils.http_download)
DownloadInfo (class in platform.utils.http_download)
E
END (in module platform.cli.generate_command)
Endpoint (class in api.client.api_client)
env (platform.terraform.terraform_api.TerraformVariableCategory attribute)
Environment (class in platform.observatory_config)
environment (platform.observatory_config.Backend attribute)
error (platform.docker.compose_runner.ProcessOutput attribute)
errors (platform.observatory_config.ObservatoryConfig property)
extra (api.server.orm.DatasetRelease attribute)
,
[1]
extract_folder (platform.workflows.workflow.Release property)
F
failed (platform.gcs.TransferStatus attribute)
fake_cloud_workspace (platform.observatory_environment.ObservatoryTestCase property)
FernetKeyType (class in platform.cli.generate_command)
fetch_dag_bag() (in module platform.airflow)
(in module platform.refactor.workflow)
fetch_dags_modules() (in module platform.airflow)
fetch_db_object() (in module api.server.orm)
fetch_workflows() (in module platform.airflow)
(in module platform.refactor.workflow)
File (class in platform.docker.builder)
file_path (platform.utils.http_download.DownloadInfo attribute)
file_type (in module api.client.model_utils)
filename (platform.utils.http_download.DownloadInfo attribute)
files_parameters() (api.client.api_client.ApiClient method)
find_free_port() (in module platform.observatory_environment)
find_replace_file() (in module platform.files)
finished (platform.sftp.SftpFolders property)
FlaskSecretKeyType (class in platform.cli.generate_command)
flower_ui_port (platform.observatory_config.Observatory attribute)
ForbiddenException
from_dict() (platform.observatory_config.Backend static method)
(platform.observatory_config.CloudSqlDatabase static method)
(platform.observatory_config.CloudWorkspace static method)
(platform.observatory_config.GoogleCloud static method)
(platform.observatory_config.Observatory static method)
(platform.observatory_config.ObservatoryConfig class method)
(platform.observatory_config.Terraform static method)
(platform.observatory_config.TerraformConfig class method)
(platform.observatory_config.VirtualMachine static method)
(platform.observatory_config.Workflow static method)
(platform.refactor.workflow.CloudWorkspace static method)
(platform.refactor.workflow.Workflow static method)
(platform.terraform.terraform_api.TerraformVariable static method)
from_hcl() (in module platform.observatory_config)
(platform.observatory_config.VirtualMachine static method)
FtpServer (class in platform.observatory_environment)
G
gcloud_activate_service_account() (platform.terraform.terraform_builder.TerraformBuilder method)
gcloud_exe_path (platform.terraform.terraform_builder.TerraformBuilder property)
gcs_blob_name_from_path() (in module platform.gcs)
gcs_blob_uri() (in module platform.gcs)
gcs_bucket_exists() (in module platform.gcs)
gcs_copy_blob() (in module platform.gcs)
gcs_create_aws_transfer() (in module platform.gcs)
gcs_create_azure_transfer() (in module platform.gcs)
gcs_create_bucket() (in module platform.gcs)
gcs_create_transfer_job() (in module platform.gcs)
gcs_delete_bucket_dir() (in module platform.gcs)
gcs_delete_old_buckets_with_prefix() (in module platform.gcs)
gcs_download_blob() (in module platform.gcs)
gcs_download_blobs() (in module platform.gcs)
gcs_hmac_key() (in module platform.gcs)
gcs_list_blobs() (in module platform.gcs)
gcs_list_buckets_with_prefix() (in module platform.gcs)
gcs_upload_file() (in module platform.gcs)
gcs_upload_files() (in module platform.gcs)
gcs_upload_transfer_manifest() (in module platform.gcs)
gcs_uri_parts() (in module platform.gcs)
generate() (in module platform.cli.cli)
generate_fernet_key() (in module platform.observatory_config)
generate_local_config() (platform.cli.generate_command.GenerateCommand method)
generate_local_config_interactive() (platform.cli.generate_command.GenerateCommand method)
generate_openapi_spec() (in module api.cli)
generate_secret_key() (in module platform.observatory_config)
generate_terraform_config() (platform.cli.generate_command.GenerateCommand method)
generate_terraform_config_interactive() (platform.cli.generate_command.GenerateCommand method)
GenerateCommand (class in platform.cli.generate_command)
get() (api.client.model_utils.ModelComposed method)
(api.client.model_utils.ModelNormal method)
(api.client.model_utils.ModelSimple method)
GET() (api.client.rest.RESTClientObject method)
get_airflow_connection_login() (in module platform.airflow)
get_airflow_connection_password() (in module platform.airflow)
get_airflow_connection_url() (in module platform.airflow)
get_allof_instances() (in module api.client.model_utils)
get_anyof_instances() (in module api.client.model_utils)
get_api_client() (in module api.utils)
get_api_key_with_prefix() (api.client.configuration.Configuration method)
get_as_list() (in module platform.files)
get_as_list_or_none() (in module platform.files)
get_basic_auth_token() (api.client.configuration.Configuration method)
get_chunks() (in module platform.files)
get_configuration_version_status() (platform.terraform.terraform_api.TerraformApi method)
get_data_path() (in module platform.airflow)
(in module platform.refactor.workflow)
get_dataset_release() (api.client.api.observatory_api.ObservatoryApi method)
(in module api.server.api)
get_dataset_releases() (api.client.api.observatory_api.ObservatoryApi method)
(in module api.server.api)
(in module platform.api)
get_default_copy() (api.client.configuration.Configuration class method)
get_discarded_args() (in module api.client.model_utils)
get_discriminated_classes() (in module api.client.model_utils)
get_discriminator_class() (in module api.client.model_utils)
get_entry_or_none() (in module platform.files)
get_file_data_and_close_file() (api.client.api_client.ApiClient static method)
get_file_hash() (in module platform.files)
get_filename_from_http_header() (in module platform.utils.url_utils)
get_filename_from_url() (in module platform.utils.url_utils)
get_hasher_() (in module platform.files)
get_host_from_settings() (api.client.configuration.Configuration method)
get_host_settings() (api.client.configuration.Configuration method)
get_http_response_json() (in module platform.utils.url_utils)
get_http_response_xml_to_dict() (in module platform.utils.url_utils)
get_http_text_response() (in module platform.utils.url_utils)
get_installed_workflows() (platform.cli.generate_command.InteractiveConfigBuilder static method)
get_item() (in module api.server.api)
get_items() (in module api.server.api)
get_latest_dataset_release() (in module platform.api)
get_latest_execution_date() (platform.utils.dag_run_sensor.DagRunSensor method)
get_logical_dates() (in module platform.refactor.sensors)
get_new_release_dates() (in module platform.api)
get_observatory_http_header() (in module platform.utils.url_utils)
get_oneof_instance() (in module api.client.model_utils)
get_possible_classes() (in module api.client.model_utils)
get_required_type_classes() (in module api.client.model_utils)
get_requirement_string() (platform.observatory_config.ObservatoryConfig method)
get_run_details() (platform.terraform.terraform_api.TerraformApi method)
get_simple_class() (in module api.client.model_utils)
get_task_instance() (platform.observatory_environment.ObservatoryEnvironment method)
get_type_error() (in module api.client.model_utils)
get_user_agent() (in module platform.utils.url_utils)
get_valid_classes_phrase() (in module api.client.model_utils)
get_vm_info() (platform.workflows.vm_workflow.TerraformVirtualMachineAPI method)
getheader() (api.client.rest.RESTResponse method)
getheaders() (api.client.rest.RESTResponse method)
google_cloud() (platform.observatory_config.ObserveratoryConfigString static method)
GoogleCloud (class in platform.observatory_config)
gunzip_files() (in module platform.files)
gzip_file_crc() (in module platform.files)
H
hash (platform.utils.http_download.DownloadInfo attribute)
hash_algorithm (platform.utils.http_download.DownloadInfo attribute)
hcl (platform.terraform.terraform_api.TerraformVariable attribute)
HEAD() (api.client.rest.RESTClientObject method)
hex_to_base64_str() (in module platform.files)
host (api.client.configuration.Configuration property)
host_package (platform.observatory_config.Observatory property)
(platform.observatory_config.PythonPackage attribute)
HOST_UID (in module platform.docker.platform_runner)
HttpServer (class in platform.observatory_environment)
I
id (api.server.orm.DatasetRelease attribute)
,
[1]
(platform.observatory_config.CloudStorageBucket attribute)
in_ipv4net() (in module api.client.rest)
in_progress (platform.gcs.TransferStatus attribute)
(platform.sftp.SftpFolders property)
indent() (in module platform.cli.cli_utils)
INDENT1 (in module platform.cli.cli_utils)
INDENT2 (in module platform.cli.cli_utils)
INDENT3 (in module platform.cli.cli_utils)
INDENT4 (in module platform.cli.cli_utils)
input_project_id (platform.observatory_config.CloudWorkspace property)
(platform.refactor.workflow.CloudWorkspace property)
install_packer_plugins() (platform.terraform.terraform_builder.TerraformBuilder method)
InteractiveConfigBuilder (class in platform.cli.generate_command)
is_base64() (in module platform.observatory_config)
is_dagrun_done() (platform.utils.dag_run_sensor.DagRunSensor method)
is_docker_running (platform.docker.platform_runner.PlatformRunner property)
is_environment_valid (platform.cli.terraform_command.TerraformCommand property)
(platform.docker.platform_runner.PlatformRunner property)
(platform.terraform.terraform_builder.TerraformBuilder property)
is_fernet_key() (in module platform.observatory_config)
is_first_dag_run() (in module platform.airflow)
is_first_release() (in module platform.api)
is_gzip() (in module platform.files)
is_ipv4() (in module api.client.rest)
is_json_validation_enabled() (in module api.client.model_utils)
is_secret_key() (in module platform.observatory_config)
is_sharded (platform.observatory_environment.Table attribute)
is_type_nullable() (in module api.client.model_utils)
is_valid (platform.observatory_config.ObservatoryConfig property)
is_valid_type() (in module api.client.model_utils)
J
JSON_SCHEMA_VALIDATION_KEYWORDS (in module api.client.configuration)
json_string_to_workflows() (in module platform.observatory_config)
(in module platform.refactor.workflow)
K
key (platform.observatory_config.ValidationError attribute)
(platform.terraform.terraform_api.TerraformVariable attribute)
key_file (api.client.configuration.Configuration attribute)
kwargs (platform.docker.builder.Template attribute)
(platform.observatory_config.Workflow attribute)
(platform.refactor.workflow.Workflow attribute)
L
list_files() (in module platform.files)
list_workspace_variables() (platform.terraform.terraform_api.TerraformApi method)
ListReleaseFunction (class in platform.workflows.workflow)
load() (platform.observatory_config.ObservatoryConfig class method)
load_and_parse_json() (in module platform.observatory_environment)
load_config() (in module platform.cli.cli)
load_csv() (in module platform.files)
load_dags_from_config() (in module platform.refactor.workflow)
load_file() (in module platform.files)
load_jsonl() (in module platform.files)
local (platform.observatory_config.BackendType attribute)
LOCAL_CONFIG_PATH (in module platform.cli.cli)
log_diff() (in module platform.observatory_environment)
logger (api.client.configuration.Configuration attribute)
(in module api.client.rest)
logger_file (api.client.configuration.Configuration attribute)
(api.client.configuration.Configuration property)
logger_file_handler (api.client.configuration.Configuration attribute)
logger_format (api.client.configuration.Configuration attribute)
(api.client.configuration.Configuration property)
logger_stream_handler (api.client.configuration.Configuration attribute)
M
machine_type (platform.observatory_config.VirtualMachine attribute)
make_dag() (in module platform.refactor.workflow)
(platform.workflows.workflow.AbstractWorkflow method)
(platform.workflows.workflow.Workflow method)
make_dummy_dag() (in module platform.observatory_environment)
make_environment() (platform.docker.compose_runner.ComposeRunner method)
(platform.docker.platform_runner.PlatformRunner method)
make_files() (platform.docker.builder.Builder method)
(platform.docker.builder.BuilderInterface method)
(platform.docker.platform_runner.PlatformRunner method)
(platform.terraform.terraform_builder.TerraformBuilder method)
make_jinja2_filename() (in module platform.utils.jinja2_utils)
make_observatory_api() (in module platform.api)
make_python_operator() (platform.workflows.workflow.Workflow method)
make_release() (platform.workflows.vm_workflow.VmCreateWorkflow method)
(platform.workflows.vm_workflow.VmDestroyWorkflow method)
(platform.workflows.workflow.AbstractWorkflow method)
make_schema() (in module platform.observatory_config)
make_sftp_connection() (in module platform.sftp)
make_snapshot_date() (in module platform.workflows.workflow)
make_sql_jinja2_filename() (in module platform.utils.jinja2_utils)
make_startup_script() (platform.terraform.terraform_builder.TerraformBuilder method)
make_task_id() (in module platform.workflows.workflow)
make_workflow() (in module platform.airflow)
make_workflow_folder() (in module platform.refactor.workflow)
(in module platform.workflows.workflow)
merge_update_files() (in module platform.files)
model_to_dict() (in module api.client.model_utils)
ModelComposed (class in api.client.model_utils)
ModelNormal (class in api.client.model_utils)
ModelSimple (class in api.client.model_utils)
modified (api.server.orm.DatasetRelease attribute)
,
[1]
module
api
api.cli
api.client
api.client.api
api.client.api.observatory_api
api.client.api_client
api.client.configuration
api.client.exceptions
api.client.model
api.client.model.dataset_release
api.client.model_utils
api.client.rest
api.server
api.server.api
api.server.app
api.server.openapi_renderer
api.server.orm
api.testing
api.utils
platform
platform.airflow
platform.api
platform.bigquery
platform.cli
platform.cli.cli
platform.cli.cli_utils
platform.cli.generate_command
platform.cli.platform_command
platform.cli.terraform_command
platform.config
platform.dags
platform.dags.dummy_telescope
platform.dags.load_dags
platform.dags.load_dags_legacy
platform.dags.load_dags_modules
platform.docker
platform.docker.builder
platform.docker.compose_runner
platform.docker.platform_runner
platform.files
platform.gcs
platform.observatory_config
platform.observatory_environment
platform.refactor
platform.refactor.sensors
platform.refactor.tasks
platform.refactor.workflow
platform.sftp
platform.sql
platform.terraform
platform.terraform.terraform_api
platform.terraform.terraform_builder
platform.utils
platform.utils.dag_run_sensor
platform.utils.http_download
platform.utils.jinja2_utils
platform.utils.proc_utils
platform.utils.url_utils
platform.workflows
platform.workflows.vm_workflow
platform.workflows.workflow
setup
module_file_path() (in module platform.config)
move_files_to_finished() (platform.sftp.SftpFolders method)
move_files_to_in_progress() (platform.sftp.SftpFolders method)
N
name (platform.cli.generate_command.FernetKeyType attribute)
(platform.cli.generate_command.FlaskSecretKeyType attribute)
(platform.observatory_config.CloudStorageBucket attribute)
(platform.observatory_config.PythonPackage attribute)
(platform.observatory_config.Workflow attribute)
(platform.refactor.workflow.Workflow attribute)
none_type (in module api.client.model_utils)
normalized_schedule_interval() (in module platform.airflow)
NotFoundException
O
oaebu_workflows() (platform.cli.generate_command.DefaultWorkflowsProject static method)
Observatory (class in platform.observatory_config)
observatory() (platform.observatory_config.ObserveratoryConfigString static method)
OBSERVATORY_API (platform.config.AirflowConns attribute)
observatory_home (platform.observatory_config.Observatory attribute)
observatory_home() (in module platform.config)
OBSERVATORY_HOME_KEY (platform.observatory_environment.ObservatoryEnvironment attribute)
observatory_platform (platform.config.Tag attribute)
ObservatoryApi (class in api.client.api.observatory_api)
ObservatoryApiEnvironment (class in api.testing)
ObservatoryConfig (class in platform.observatory_config)
ObservatoryConfigValidator (class in platform.observatory_config)
ObservatoryEnvironment (class in platform.observatory_environment)
ObservatoryTestCase (class in platform.observatory_environment)
ObserveratoryConfigString (class in platform.observatory_config)
on_failure_callback() (in module platform.airflow)
openapi_types() (api.client.model.dataset_release.DatasetRelease method)
OpenApiException
OpenApiModel (class in api.client.model_utils)
OpenApiRenderer (class in api.server.openapi_renderer)
OPTIONS() (api.client.rest.RESTClientObject method)
order_response_types() (in module api.client.model_utils)
organization (platform.observatory_config.Terraform attribute)
output (platform.docker.compose_runner.ProcessOutput attribute)
output_file_name (platform.docker.builder.File attribute)
(platform.docker.builder.Template property)
output_project_id (platform.observatory_config.CloudWorkspace property)
(platform.refactor.workflow.CloudWorkspace property)
P
package (platform.observatory_config.Observatory attribute)
(platform.observatory_config.WorkflowsProject attribute)
package_name (platform.observatory_config.WorkflowsProject attribute)
package_type (platform.observatory_config.Observatory attribute)
(platform.observatory_config.WorkflowsProject attribute)
packer_exe_path (platform.terraform.terraform_builder.TerraformBuilder property)
parallel_tasks() (platform.workflows.workflow.Workflow method)
parameters_to_multipart() (api.client.api_client.ApiClient method)
parameters_to_tuples() (api.client.api_client.ApiClient method)
parse_buckets() (platform.observatory_config.CloudStorageBucket static method)
parse_cloud_workspaces() (platform.observatory_config.CloudWorkspace static method)
(platform.refactor.workflow.CloudWorkspace static method)
parse_datetime() (in module platform.workflows.vm_workflow)
parse_dict_to_list() (in module platform.observatory_config)
parse_retry_after() (in module platform.utils.url_utils)
parse_workflows() (platform.observatory_config.Workflow static method)
(platform.refactor.workflow.Workflow static method)
parse_workflows_projects() (platform.observatory_config.WorkflowsProject static method)
part_file_path() (in module platform.files)
partition_date (api.server.orm.DatasetRelease attribute)
,
[1]
PartitionRelease (class in platform.workflows.workflow)
password (api.client.configuration.Configuration attribute)
PATCH() (api.client.rest.RESTClientObject method)
path (platform.docker.builder.File attribute)
(platform.docker.builder.Template attribute)
PendulumDateTimeEncoder (class in platform.observatory_config)
(class in platform.refactor.workflow)
plan_variable_changes() (platform.terraform.terraform_api.TerraformApi method)
platform
module
platform() (in module platform.cli.cli)
platform.airflow
module
platform.api
module
platform.bigquery
module
platform.cli
module
platform.cli.cli
module
platform.cli.cli_utils
module
platform.cli.generate_command
module
platform.cli.platform_command
module
platform.cli.terraform_command
module
platform.config
module
platform.dags
module
platform.dags.dummy_telescope
module
platform.dags.load_dags
module
platform.dags.load_dags_legacy
module
platform.dags.load_dags_modules
module
platform.docker
module
platform.docker.builder
module
platform.docker.compose_runner
module
platform.docker.platform_runner
module
platform.files
module
platform.gcs
module
platform.observatory_config
module
platform.observatory_environment
module
platform.refactor
module
platform.refactor.sensors
module
platform.refactor.tasks
module
platform.refactor.workflow
module
platform.sftp
module
platform.sql
module
platform.terraform
module
platform.terraform.terraform_api
module
platform.terraform.terraform_builder
module
platform.utils
module
platform.utils.dag_run_sensor
module
platform.utils.http_download
module
platform.utils.jinja2_utils
module
platform.utils.proc_utils
module
platform.utils.url_utils
module
platform.workflows
module
platform.workflows.vm_workflow
module
platform.workflows.workflow
module
platform_check_dependencies() (in module platform.cli.cli)
PLATFORM_NAME (in module platform.cli.cli)
platform_start() (in module platform.cli.cli)
platform_stop() (in module platform.cli.cli)
PlatformCommand (class in platform.cli.platform_command)
PlatformRunner (class in platform.docker.platform_runner)
poke() (platform.airflow.PreviousDagRunSensor method)
(platform.utils.dag_run_sensor.DagRunSensor method)
pool (api.client.api_client.ApiClient property)
POST() (api.client.rest.RESTClientObject method)
post_dataset_release() (api.client.api.observatory_api.ObservatoryApi method)
(in module api.server.api)
post_item() (in module api.server.api)
postgres_password (platform.observatory_config.Observatory attribute)
prefix_dir (platform.utils.http_download.DownloadInfo attribute)
PreviousDagRunSensor (class in platform.airflow)
PRIMITIVE_TYPES (in module api.client.model_utils)
print_summary() (platform.cli.terraform_command.TerraformCommand method)
print_variable() (platform.cli.terraform_command.TerraformCommand method)
print_variable_update() (platform.cli.terraform_command.TerraformCommand method)
ProcessOutput (class in platform.docker.compose_runner)
production (platform.observatory_config.Environment attribute)
project_id (platform.observatory_config.CloudWorkspace property)
(platform.observatory_config.GoogleCloud attribute)
(platform.refactor.workflow.CloudWorkspace property)
proxy (api.client.configuration.Configuration attribute)
proxy_headers (api.client.configuration.Configuration attribute)
PUT() (api.client.rest.RESTClientObject method)
put_dataset_release() (api.client.api.observatory_api.ObservatoryApi method)
(in module api.server.api)
put_item() (in module api.server.api)
python_packages (platform.observatory_config.ObservatoryConfig property)
PYTHON_VERSION (in module platform.docker.platform_runner)
PythonPackage (class in platform.observatory_config)
R
random_id() (in module platform.observatory_environment)
read_credentials() (platform.observatory_config.GoogleCloud method)
read_line_boundary() (in module platform.files)
read_only_vars (api.client.model.dataset_release.DatasetRelease attribute)
records (platform.observatory_environment.Table attribute)
redis_port (platform.observatory_config.Observatory attribute)
refresh_api_key_hook (api.client.configuration.Configuration attribute)
region (platform.observatory_config.GoogleCloud attribute)
Release (class in platform.workflows.workflow)
release_folder (platform.workflows.workflow.ChangefileRelease property)
(platform.workflows.workflow.PartitionRelease property)
(platform.workflows.workflow.Release property)
(platform.workflows.workflow.SnapshotRelease property)
RELEASE_INFO (platform.workflows.workflow.Workflow attribute)
ReleaseFunction (class in platform.workflows.workflow)
remove_session() (in module api.server.app)
remove_uncoercible() (in module api.client.model_utils)
render() (api.server.openapi_renderer.OpenApiRenderer method)
render_path() (in module api.client.exceptions)
render_template() (in module api.server.openapi_renderer)
(in module platform.utils.jinja2_utils)
(platform.docker.builder.Builder method)
(platform.workflows.workflow.WorkflowBashOperator method)
rendered_file_name() (in module platform.docker.builder)
request() (api.client.api_client.ApiClient method)
(api.client.rest.RESTClientObject method)
requeue_once_if_bad_hash() (in module platform.utils.http_download)
required_properties (api.client.model.dataset_release.DatasetRelease attribute)
Response (in module api.server.api)
RESTClientObject (class in api.client.rest)
RESTResponse (class in api.client.rest)
result_key (api.client.model_utils.cached_property attribute)
retries (api.client.configuration.Configuration attribute)
retry (platform.utils.http_download.DownloadInfo attribute)
retry_get_url() (in module platform.utils.url_utils)
retry_session() (in module platform.utils.url_utils)
return_code (platform.docker.compose_runner.ProcessOutput attribute)
run_task() (platform.observatory_environment.ObservatoryEnvironment method)
run_terraform() (platform.workflows.vm_workflow.VmCreateWorkflow method)
(platform.workflows.vm_workflow.VmDestroyWorkflow method)
S
safe_chars_for_path_param (api.client.configuration.Configuration attribute)
sanitize_for_serialization() (api.client.api_client.ApiClient class method)
save() (platform.observatory_config.ObservatoryConfig method)
(platform.observatory_config.TerraformConfig method)
save_airflow_main_vm() (platform.observatory_config.TerraformConfig method)
save_airflow_worker_vm() (platform.observatory_config.TerraformConfig method)
save_backend() (platform.observatory_config.ObservatoryConfig method)
save_cloud_sql_database() (platform.observatory_config.TerraformConfig method)
save_empty_file() (in module platform.observatory_environment)
save_google_cloud() (platform.observatory_config.ObservatoryConfig method)
save_jsonl() (in module platform.files)
save_jsonl_gz() (in module platform.files)
save_observatory() (platform.observatory_config.ObservatoryConfig method)
save_terraform() (platform.observatory_config.ObservatoryConfig method)
save_workflows_projects() (platform.observatory_config.ObservatoryConfig method)
save_yaml() (in module platform.observatory_config)
ScheduleInterval (in module platform.airflow)
schema_file_path (platform.observatory_environment.Table attribute)
secrets() (in module platform.cli.cli)
select_header_accept() (api.client.api_client.ApiClient method)
select_header_content_type() (api.client.api_client.ApiClient method)
send_slack_msg() (in module platform.airflow)
sensitive (platform.terraform.terraform_api.TerraformVariable attribute)
sequence_end (api.server.orm.DatasetRelease attribute)
,
[1]
sequence_start (api.server.orm.DatasetRelease attribute)
,
[1]
serve_() (platform.observatory_environment.HttpServer static method)
server_operation_index (api.client.configuration.Configuration attribute)
server_operation_variables (api.client.configuration.Configuration attribute)
ServiceException
session_ (in module api.server.api)
(in module api.server.app)
(in module api.server.orm)
set_attribute() (api.client.model_utils.OpenApiModel method)
set_default() (api.client.configuration.Configuration class method)
set_default_header() (api.client.api_client.ApiClient method)
set_editable_observatory_api() (platform.cli.generate_command.InteractiveConfigBuilder static method)
set_editable_observatory_platform() (platform.cli.generate_command.InteractiveConfigBuilder static method)
set_session() (in module api.server.orm)
set_task_state() (in module platform.workflows.workflow)
setup
module
setup_mock_file_download() (platform.observatory_environment.ObservatoryTestCase method)
sftp_home (platform.sftp.SftpFolders property)
SftpFolders (class in platform.sftp)
SftpServer (class in platform.observatory_environment)
should_bypass_proxies() (in module api.client.rest)
should_ignore() (in module platform.terraform.terraform_builder)
skip_download() (in module platform.utils.http_download)
skip_task() (platform.observatory_environment.ObservatoryEnvironment method)
SLACK (platform.config.AirflowConns attribute)
snapshot_date (api.server.orm.DatasetRelease attribute)
,
[1]
SnapshotRelease (class in platform.workflows.workflow)
sort_schema_cmd() (in module platform.cli.cli)
split_file() (in module platform.files)
split_file_and_compress() (in module platform.files)
sql_templates_path() (in module platform.config)
ssl_ca_cert (api.client.configuration.Configuration attribute)
staging (platform.observatory_config.Environment attribute)
start() (platform.docker.compose_runner.ComposeRunner method)
(platform.observatory_environment.HttpServer method)
stop() (platform.docker.compose_runner.ComposeRunner method)
(platform.observatory_environment.HttpServer method)
stream_process() (in module platform.utils.proc_utils)
success (platform.gcs.TransferStatus attribute)
T
Table (class in platform.observatory_environment)
table_name (platform.observatory_environment.Table attribute)
Tag (class in platform.config)
TARGET_ADDRS (in module platform.workflows.vm_workflow)
task1 (in module platform.dags.dummy_telescope)
task_callable() (platform.workflows.workflow.AbstractWorkflow method)
(platform.workflows.workflow.Workflow method)
temp_folder_path (api.client.configuration.Configuration attribute)
Template (class in platform.docker.builder)
Terraform (class in platform.observatory_config)
TERRAFORM (platform.config.AirflowConns attribute)
terraform (platform.observatory_config.BackendType attribute)
(platform.terraform.terraform_api.TerraformVariableCategory attribute)
terraform() (in module platform.cli.cli)
(platform.observatory_config.ObserveratoryConfigString static method)
terraform_api (platform.workflows.vm_workflow.TerraformVirtualMachineAPI property)
terraform_check_dependencies() (in module platform.cli.cli)
TERRAFORM_CONFIG_PATH (in module platform.cli.cli)
TERRAFORM_CREATE_VM_KEY (in module platform.workflows.vm_workflow)
terraform_credentials_path() (in module platform.config)
TERRAFORM_NAME (in module platform.cli.cli)
terraform_variables() (platform.observatory_config.TerraformConfig method)
terraform_workspace_id (platform.observatory_config.TerraformConfig property)
TERRAFORM_WORKSPACE_VERSION (platform.terraform.terraform_api.TerraformApi attribute)
TerraformApi (class in platform.terraform.terraform_api)
TerraformBuilder (class in platform.terraform.terraform_builder)
TerraformCommand (class in platform.cli.terraform_command)
TerraformConfig (class in platform.observatory_config)
TerraformVariable (class in platform.terraform.terraform_api)
TerraformVariableCategory (class in platform.terraform.terraform_api)
TerraformVirtualMachineAPI (class in platform.workflows.vm_workflow)
test_fixtures_path() (in module platform.observatory_environment)
tier (platform.observatory_config.CloudSqlDatabase attribute)
to_datetime_utc() (in module api.server.orm)
to_debug_report() (api.client.configuration.Configuration method)
to_dict() (api.client.model_utils.ModelComposed method)
(api.client.model_utils.ModelNormal method)
(api.server.openapi_renderer.OpenApiRenderer method)
(platform.observatory_config.CloudWorkspace method)
(platform.observatory_config.Workflow method)
(platform.refactor.workflow.CloudWorkspace method)
(platform.refactor.workflow.Workflow method)
(platform.terraform.terraform_api.TerraformVariable method)
to_hcl() (in module platform.observatory_config)
(platform.observatory_config.CloudSqlDatabase method)
(platform.observatory_config.GoogleCloud method)
(platform.observatory_config.Observatory method)
(platform.observatory_config.VirtualMachine method)
to_str() (api.client.model_utils.ModelComposed method)
(api.client.model_utils.ModelNormal method)
(api.client.model_utils.ModelSimple method)
token_from_file() (platform.terraform.terraform_api.TerraformApi static method)
TransferStatus (class in platform.gcs)
transform_bucket (platform.observatory_config.CloudWorkspace property)
(platform.refactor.workflow.CloudWorkspace property)
transform_folder (platform.workflows.workflow.Release property)
type (platform.observatory_config.Backend attribute)
(platform.observatory_config.PythonPackage attribute)
type_error_message() (in module api.client.model_utils)
U
ui_url (platform.cli.platform_command.PlatformCommand property)
UnauthorizedException
UPCONVERSION_TYPE_PAIRS (in module api.client.model_utils)
update() (api.server.orm.DatasetRelease method)
update_params_for_auth() (api.client.api_client.ApiClient method)
update_terraform_variable() (platform.workflows.vm_workflow.VmCreateWorkflow method)
(platform.workflows.vm_workflow.VmDestroyWorkflow method)
update_terraform_vm_create_variable() (platform.workflows.vm_workflow.TerraformVirtualMachineAPI method)
update_workspace() (platform.cli.terraform_command.TerraformCommand method)
update_workspace_variable() (platform.terraform.terraform_api.TerraformApi method)
update_workspace_variables() (platform.terraform.terraform_api.TerraformApi method)
upload (platform.sftp.SftpFolders property)
upload_configuration_files() (platform.terraform.terraform_api.TerraformApi static method)
url (platform.utils.http_download.DownloadInfo attribute)
user_agent (api.client.api_client.ApiClient property)
username (api.client.configuration.Configuration attribute)
V
validate_and_convert_types() (in module api.client.model_utils)
validate_file_hash() (in module platform.files)
validate_get_composed_info() (in module api.client.model_utils)
ValidationError (class in platform.observatory_config)
validations (api.client.model.dataset_release.DatasetRelease attribute)
value (platform.observatory_config.ValidationError attribute)
(platform.terraform.terraform_api.TerraformVariable attribute)
var_id (platform.terraform.terraform_api.TerraformVariable attribute)
verbosity (platform.cli.terraform_command.TerraformCommand property)
VERBOSITY_DEBUG (platform.terraform.terraform_api.TerraformApi attribute)
VERBOSITY_INFO (platform.terraform.terraform_api.TerraformApi attribute)
VERBOSITY_WARNING (platform.terraform.terraform_api.TerraformApi attribute)
verify_ssl (api.client.configuration.Configuration attribute)
VirtualMachine (class in platform.observatory_config)
VM_RUNTIME_H_WARNING (in module platform.workflows.vm_workflow)
VmCreateWorkflow (class in platform.workflows.vm_workflow)
VmDestroyWorkflow (class in platform.workflows.vm_workflow)
W
wait_for_airflow_ui() (platform.cli.platform_command.PlatformCommand method)
wait_for_process() (in module platform.utils.proc_utils)
wait_for_url() (in module platform.utils.url_utils)
WARNING_FREQUENCY_H (in module platform.workflows.vm_workflow)
worker_() (in module platform.utils.http_download)
Workflow (class in platform.observatory_config)
(class in platform.refactor.workflow)
(class in platform.workflows.workflow)
workflow (in module platform.dags.load_dags_legacy)
workflow_folder (platform.workflows.workflow.Release property)
WorkflowBashOperator (class in platform.workflows.workflow)
WorkflowFunction (in module platform.workflows.workflow)
workflows (in module platform.dags.load_dags_legacy)
WORKFLOWS (platform.config.AirflowVars attribute)
workflows_projects() (platform.observatory_config.ObserveratoryConfigString static method)
workflows_to_json_string() (in module platform.observatory_config)
(in module platform.refactor.workflow)
WorkflowsProject (class in platform.observatory_config)
workspace_id (platform.workflows.vm_workflow.TerraformVirtualMachineAPI property)
workspace_id() (platform.terraform.terraform_api.TerraformApi method)
WORKSPACE_PREFIX (platform.observatory_config.TerraformConfig attribute)
write_to_file() (in module platform.files)
X
XCOM_DESTROY_TIME_VM (in module platform.workflows.vm_workflow)
XCOM_PREV_START_TIME_VM (in module platform.workflows.vm_workflow)
XCOM_START_TIME_VM (in module platform.workflows.vm_workflow)
XCOM_TERRAFORM_RUN_ID (in module platform.workflows.vm_workflow)
XCOM_WARNING_TIME (in module platform.workflows.vm_workflow)
Y
yield_csv() (in module platform.files)
yield_jsonl() (in module platform.files)
Z
zone (platform.observatory_config.GoogleCloud attribute)
Read the Docs
v: latest
Versions
latest
stable
Downloads
On Read the Docs
Project Home
Builds