Index

_

__call__() (singleton.Singleton method) __client() (async_mongo_client.AsyncMongo method) __DEFAULT_LOG_LEVEL (logger_client.LoggerClient attribute) __default_log_level() (logger_client.LoggerClient static method) __DEFAULT_LOGGING_FORMAT (logger_client.LoggerClient attribute) __DEFAULT_TIME_FORMAT (logger_client.LoggerClient attribute) __EXECUTION_COLLECTION (execution_repository.ExecutionRepository attribute) __get_cached_execution_model() (ska_src_api_global_execution.service.execution_service.ExecutionService method) __get_collection() (async_mongo_client.AsyncMongo method) __get_other_static_config_files() (config_client.ConfigClient method) __get_queue_from_site_capabilities() (ska_src_api_global_execution.service.queue_service.QueueService method) __get_user_name_from_token() (ska_src_api_global_execution.service.execution_service.ExecutionService method) __load_static_config_files() (config_client.ConfigClient method) __logging_format() (logger_client.LoggerClient static method) __MONGO_DATABASE (async_mongo_client.AsyncMongo attribute) __MONGO_HOST (async_mongo_client.AsyncMongo attribute) __MONGO_PASSWORD (async_mongo_client.AsyncMongo attribute)

__MONGO_PORT (async_mongo_client.AsyncMongo attribute) __MONGO_USERNAME (async_mongo_client.AsyncMongo attribute) __setup_client() (async_mongo_client.AsyncMongo method) __time_format() (logger_client.LoggerClient static method) __transform_from_dict() (async_mongo_client.AsyncMongo static method) __transform_into_dict() (async_mongo_client.AsyncMongo static method) __update_repository_if_state_changed() (ska_src_api_global_execution.service.execution_service.ExecutionService method) _build_query_params() (in module openapi) _ensure_valid_auth_token() (ska_src_api_global_execution.session.session.AuthenticatedOAuth2Session method) _format_nodes() (ska_src_api_global_execution.service.broker_service.SiteCapabilitiesComputeClient static method) (ska_src_api_global_execution.service.broker_service.SiteCapabilitiesStorageClient static method) _get_access_token_from_authz_header() (ska_src_api_global_execution.session.session.AuthenticatedOAuth2Session method) _get_param_placeholder() (in module openapi) _instances (singleton.Singleton attribute) _nameToLevel (logger_client.LoggerClient attribute) _parse_resources_by_site() (ska_src_api_global_execution.service.execution_broker.ExecutionBroker static method) _update_authz_header() (ska_src_api_global_execution.session.session.AuthenticatedOAuth2Session method)

A

AbstractConfig (class in ska_src_api_global_execution.models.config) add_dict() (redis.RedisCache method) add_string() (redis.RedisCache method) add_to_job_definition() (panda_client.PandaClient static method) add_to_sorted_set() (redis.RedisCache method) additional_info (ska_src_api_global_execution.models.response.ExecutionSubmissionResponse attribute) annotations (ska_src_api_global_execution.models.config.PandaJobDeploymentConfig attribute) app (in module server) arguments (ska_src_api_global_execution.models.workstep.WorkStepModel attribute)

async_mongo_client module AsyncMongo (class in async_mongo_client) AuthenticatedDataManagementAPIOAuth2Session (class in ska_src_api_global_execution.session) (class in ska_src_api_global_execution.session.data_management_api_oauth2_session) AuthenticatedOAuth2Session (class in ska_src_api_global_execution.session.session) AuthenticatedSiteCapabilitiesAPIOAuth2Session (class in ska_src_api_global_execution.session) (class in ska_src_api_global_execution.session.site_capabilities_api_oauth2_session) authentication_disabled (in module workstep)

B

background_task_manager module BackgroundTaskManager (class in background_task_manager) backoff_limit (ska_src_api_global_execution.models.config.PandaJobDeploymentConfig attribute) BadRequest batch (ska_src_api_global_execution.models.workstep.ExecutionType attribute) batch_job_executor_provider() (in module beans) BatchJobExecutor (class in ska_src_api_global_execution.factory.batch_job_executor) beans module build_audience() (iam_client.IAMClient method) build_client_id() (iam_client.IAMClient method) build_client_secret() (iam_client.IAMClient method) build_container_image() (panda_client.PandaClient static method)

build_cpu_required() (panda_client.PandaClient static method) build_job_definition() (panda_client.PandaClient static method) build_jobs_count() (panda_client.PandaClient static method) build_memory_required() (panda_client.PandaClient static method) build_no_build() (panda_client.PandaClient static method) build_no_separate_log() (panda_client.PandaClient static method) build_out_ds() (panda_client.PandaClient static method) build_panda_job_script() (panda_client.PandaClient static method) build_payload_and_auth_for_refresh_token() (iam_client.IAMClient method) build_payload_and_auth_for_token_exchange() (iam_client.IAMClient method) build_prod_source_label() (panda_client.PandaClient static method) build_queue_name() (panda_client.PandaClient static method) build_scope() (iam_client.IAMClient method) build_vo() (panda_client.PandaClient static method) build_working_group() (panda_client.PandaClient static method)

C

cache module Cache (class in cache) cache_health() (in module status) CACHE_HOST (in module ska_src_api_global_execution.models.constants) CACHE_KEY_TEMPLATE (iam_client.IAMClient attribute) CACHE_PORT (in module ska_src_api_global_execution.models.constants) call_token_endpoint() (iam_client.IAMClient method) ClientNotDefinedError ClientTokenError close() (async_mongo_client.AsyncMongo method) comma_separate_list() (in module ska_src_api_global_execution.service.utils) Common (class in dependencies) completed (ska_src_api_global_execution.models.workstep.ExecutionState attribute) conditional_verify_permission_for_service_route_depends() (dependencies.Permissions static method) config (in module server) (in module status) config_client module

config_client() (in module beans) ConfigClient (class in config_client) container_image (ska_src_api_global_execution.models.workstep.WorkStepModel attribute) (ska_src_api_global_execution.models.workstep.WorkStepModelV1 attribute) convert_readme_to_html_docs() (in module utility) CORSMiddleware_params (in module server) cpu_cores (ska_src_api_global_execution.models.workstep.SystemParameters attribute) (ska_src_api_global_execution.models.workstep.WorkStepModel attribute) create_custom_openapi_schema() (in module openapi) create_execution_id_to_user_mapping() (execution_repository.ExecutionRepository method) create_job() (kubernetes.Kubernetes method) created_at (ska_src_api_global_execution.models.workstep.WorkStepModel attribute) created_by (ska_src_api_global_execution.models.workstep.WorkStepModel attribute) (ska_src_api_global_execution.models.workstep.WorkStepModelV1 attribute) custom_openapi() (in module server) CustomException CustomHTTPException

D

data_capabilities_service_token module data_management_api_health() (in module status) data_management_client() (external_api_clients.ExternalApiClients method) database_health() (in module status) DataLocationModel (class in ska_src_api_global_execution.models.workstep) DataManagamentStorageAreaClient (class in ska_src_api_global_execution.service.broker_service) DataManagementServiceToken (class in data_capabilities_service_token) decode_token_payload() (ska_src_api_global_execution.service.user_service.UserService static method) default_request_session() (in module beans) defined (ska_src_api_global_execution.models.workstep.ExecutionState attribute) delete_many() (async_mongo_client.AsyncMongo method)

delete_one() (async_mongo_client.AsyncMongo method) dependencies module dependencies (in module workstep) dependent_services (ska_src_api_global_execution.models.HealthResponse attribute) (ska_src_api_global_execution.models.response.HealthResponse attribute) description (ska_src_api_global_execution.models.workstep.WorkStepModel attribute) (ska_src_api_global_execution.models.workstep.WorkStepModelV1 attribute) detail (ska_src_api_global_execution.models.GenericErrorResponse attribute) (ska_src_api_global_execution.models.response.GenericErrorResponse attribute) docs module docs_router (in module docs)

E

env_var_pattern (config_client.ConfigClient attribute) env_var_with_default_pattern (config_client.ConfigClient attribute) error (ska_src_api_global_execution.models.execution_model.ExecutionModel attribute) error_code (ska_src_api_global_execution.models.execution_model.ExecutionModel attribute) exceptions module exchange_token() (iam_client.IAMClient method) (in module ska_src_api_global_execution.job_submission.panda) executable_entrypoint (ska_src_api_global_execution.models.workstep.WorkStepModel attribute) (ska_src_api_global_execution.models.workstep.WorkStepModelV1 attribute) execute_one() (background_task_manager.BackgroundTaskManager method) execution (ska_src_api_global_execution.models.workstep.WorkStepModel attribute) (ska_src_api_global_execution.models.workstep.WorkStepModelV1 attribute) EXECUTION_DATA_TEMPLATE (execution_repository.ExecutionRepository attribute) EXECUTION_FAILED (ska_src_api_global_execution.models.execution_model.ExecutionErrorCode attribute)

EXECUTION_ID (in module ska_src_api_global_execution.models.constants) EXECUTION_ID_TO_USER_INDEX_TEMPLATE (execution_repository.ExecutionRepository attribute) execution_repository module ExecutionBroker (class in ska_src_api_global_execution.service.execution_broker) ExecutionErrorCode (class in ska_src_api_global_execution.models.execution_model) ExecutionModel (class in ska_src_api_global_execution.models.execution_model) ExecutionRepository (class in execution_repository) ExecutionService (class in ska_src_api_global_execution.service.execution_service) ExecutionState (class in ska_src_api_global_execution.models.workstep) ExecutionSubmissionResponse (class in ska_src_api_global_execution.models.response) ExecutionType (class in ska_src_api_global_execution.models.workstep) external_api_clients module ExternalApiClients (class in external_api_clients)

F

failed (ska_src_api_global_execution.models.workstep.ExecutionState attribute) fetch() (ska_src_api_global_execution.factory.batch_job_executor.BatchJobExecutor method) (ska_src_api_global_execution.factory.batch_job_executor.TestBatchJobExecutor method) (ska_src_api_global_execution.factory.panda_batch_job_executor.PandaBatchJobExecutor method) (ska_src_api_global_execution.service.execution_service.ExecutionService method) fetch_health_status() (in module status)

find_many() (async_mongo_client.AsyncMongo method) find_one() (async_mongo_client.AsyncMongo method) finished_at (ska_src_api_global_execution.models.workstep.WorkStepModel attribute) (ska_src_api_global_execution.models.workstep.WorkStepModelV1 attribute) FlowNotImplementedError format (ska_src_api_global_execution.models.workstep.DataLocationModel attribute)

G

generate_code_sample() (in module openapi) GenericErrorResponse (class in ska_src_api_global_execution.models) (class in ska_src_api_global_execution.models.response) GenericOperationResponse (class in ska_src_api_global_execution.models) (class in ska_src_api_global_execution.models.response) get() (config_client.ConfigClient method) (oauth2_service_token.OAuth2ServiceToken method) (ska_src_api_global_execution.session.session.AuthenticatedOAuth2Session method) get_api_server_url_from_request() (in module utility) get_background_tasks_manager() (in module beans) get_base_url_from_request() (in module utility) get_cache_token() (cache.Cache method) (redis.RedisCache method) get_cached_token_or_refresh() (iam_client.IAMClient method) get_compute_from_site_capabilities() (ska_src_api_global_execution.service.broker_service.SiteCapabilitiesComputeClient method) get_config_path() (config_client.ConfigClient method) get_count_sorted_set() (redis.RedisCache method) get_data_management_service_token() (oauth2_service_token_factory.OAuth2ServiceTokenFactory method) get_dict() (config_client.ConfigClient method) (redis.RedisCache method) get_dict_or_none() (redis.RedisCache method) get_execution_model() (execution_repository.ExecutionRepository method) get_external_api_clients() (in module beans) get_from_env() (in module ska_src_api_global_execution.service.utils) get_iam_client() (in module ska_src_api_global_execution.job_submission.panda) get_iam_constants() (in module beans) get_id_token_expiration_time() (iam_client.IAMClient method) get_job_repository() (in module beans)

get_job_status() (global_execution_client.GlobalExecutionClient method) (in module workstep) get_jobs_service() (in module beans) get_kubernetes_client() (in module beans) get_latest_execution_ids() (execution_repository.ExecutionRepository method) get_latest_execution_models() (execution_repository.ExecutionRepository method) get_latest_from_sorted_set() (redis.RedisCache method) get_list() (config_client.ConfigClient method) get_logger() (logger_client.LoggerClient static method) get_mongo_client() (in module beans) get_oauth2_service_service_token_factory() (in module beans) get_panda_client() (in module beans) get_parent_site_ids_from_identifiers() (ska_src_api_global_execution.service.broker_service.SiteCapabilitiesStorageClient method) get_queue_name_for_panda_batch_job() (ska_src_api_global_execution.service.queue_service.QueueService method) get_redis_cache() (in module beans) get_site_capabilities_queue_client() (in module beans) get_site_capabilities_service_token() (oauth2_service_token_factory.OAuth2ServiceTokenFactory method) get_storage_from_site_capabilities() (ska_src_api_global_execution.service.broker_service.SiteCapabilitiesStorageClient method) get_string() (config_client.ConfigClient method) (redis.RedisCache method) get_string_or_none() (redis.RedisCache method) get_sync() (ska_src_api_global_execution.session.session.AuthenticatedOAuth2Session method) get_task() (panda_client.PandaClient method) get_url_for_app_from_request() (in module utility) get_user_name_from_execution_id() (execution_repository.ExecutionRepository method) global_execution_client module GlobalExecutionClient (class in global_execution_client)

H

handle_client_exceptions() (in module exceptions) handle_exceptions() (in module exceptions) health() (global_execution_client.GlobalExecutionClient method) (in module status) HealthResponse (class in ska_src_api_global_execution.models) (class in ska_src_api_global_execution.models.response)

HealthResponse.DependentServices (class in ska_src_api_global_execution.models) (class in ska_src_api_global_execution.models.response) HealthResponse.DependentServices.DependentServiceStatus (class in ska_src_api_global_execution.models) (class in ska_src_api_global_execution.models.response)

I

iam module IAM (class in iam) iam_client module iam_endpoint_authorization (iam.IAM property) iam_endpoint_device_authorization (iam.IAM property) iam_endpoint_introspection (iam.IAM property) iam_endpoint_token (iam.IAM property) IAMClient (class in iam_client) IAMEndpointNotFoundInWellKnown id (ska_src_api_global_execution.models.execution_model.ExecutionModel attribute) (ska_src_api_global_execution.models.response.ExecutionSubmissionResponse attribute) (ska_src_api_global_execution.models.workstep.DataLocationModel attribute) (ska_src_api_global_execution.models.workstep.WorkStepModel attribute) (ska_src_api_global_execution.models.workstep.WorkStepModelV1 attribute) image (ska_src_api_global_execution.models.config.PandaJobDeploymentConfig attribute)

image_pull_policy (ska_src_api_global_execution.models.config.PandaJobDeploymentConfig attribute) increment_request_counter() (dependencies.Common method) increment_requests_counter_depends() (dependencies.Common static method) initialize_execution_data() (execution_repository.ExecutionRepository method) input_data (ska_src_api_global_execution.models.workstep.WorkStepModelV1 attribute) inputs (ska_src_api_global_execution.models.workstep.WorkStepModel attribute) insert_many() (async_mongo_client.AsyncMongo method) insert_one() (async_mongo_client.AsyncMongo method) interactive (ska_src_api_global_execution.models.workstep.ExecutionType attribute) interactive_job_executor_provider() (in module beans) InteractiveJobExecutor (class in ska_src_api_global_execution.factory.interactive_job_executor) InternalServerError INVALID_WORKSTEP (ska_src_api_global_execution.models.execution_model.ExecutionErrorCode attribute) is_a_singularity_pilot() (panda_client.PandaClient static method) is_container_image_required() (panda_client.PandaClient static method) is_valid() (ska_src_api_global_execution.models.config.AbstractConfig method) (ska_src_api_global_execution.models.config.PandaJobDeploymentConfig method)

J

JEDI_TASK_ID (in module ska_src_api_global_execution.models.constants)

K

kubernetes module

Kubernetes (class in kubernetes)

L

label (ska_src_api_global_execution.models.workstep.WorkStepModel attribute) labels (ska_src_api_global_execution.models.config.PandaJobDeploymentConfig attribute) lifespan() (in module server) load() (config_client.ConfigClient method) load_and_process_yaml() (config_client.ConfigClient method) locate_replicas_file_from_datamanagent() (ska_src_api_global_execution.service.broker_service.DataManagamentStorageAreaClient method) lock() (redis.RedisCache method) logger (async_mongo_client.AsyncMongo attribute) (config_client.ConfigClient attribute) (dependencies.Permissions attribute) (execution_repository.ExecutionRepository attribute) (external_api_clients.ExternalApiClients attribute) (global_execution_client.GlobalExecutionClient attribute) (iam_client.IAMClient attribute) (in module server) (in module singleton) (in module ska_src_api_global_execution.job_submission.panda) (in module ska_src_api_global_execution.service.utils) (in module status) (in module workstep) (kubernetes.Kubernetes attribute) (logger_client.LoggerClient attribute) (oauth2_service_token_factory.OAuth2ServiceTokenFactory attribute) (panda_client.PandaClient attribute) (redis.RedisCache attribute) (ska_src_api_global_execution.factory.batch_job_executor.TestBatchJobExecutor attribute) (ska_src_api_global_execution.factory.panda_batch_job_executor.PandaBatchJobExecutor attribute) (ska_src_api_global_execution.service.broker_service.DataManagamentStorageAreaClient attribute) (ska_src_api_global_execution.service.broker_service.SiteCapabilitiesComputeClient attribute) (ska_src_api_global_execution.service.broker_service.SiteCapabilitiesStorageClient attribute) (ska_src_api_global_execution.service.execution_broker.ExecutionBroker attribute) (ska_src_api_global_execution.service.execution_service.ExecutionService attribute) (ska_src_api_global_execution.service.queue_service.QueueService attribute) (ska_src_api_global_execution.service.user_service.UserService attribute)

logger_client module logger_properties (config_client.ConfigClient property) LoggerClient (class in logger_client)

M

main() (in module ska_src_api_global_execution.job_submission.panda) max_walltime_hours (ska_src_api_global_execution.models.workstep.SystemParameters attribute) memory_gb (ska_src_api_global_execution.models.workstep.SystemParameters attribute) (ska_src_api_global_execution.models.workstep.WorkStepModel attribute) metadata (ska_src_api_global_execution.models.execution_model.ExecutionModel attribute) method (ska_src_api_global_execution.models.workstep.ProvenanceJson attribute) model_config (ska_src_api_global_execution.models.execution_model.ExecutionModel attribute) module async_mongo_client background_task_manager beans cache config_client data_capabilities_service_token dependencies docs exceptions execution_repository external_api_clients global_execution_client iam iam_client kubernetes logger_client oauth2_service_token oauth2_service_token_factory openapi panda_client redis request_timeout_adapter server singleton site_capabilities_service_token ska_src_api_global_execution ska_src_api_global_execution.factory ska_src_api_global_execution.factory.batch_job_executor ska_src_api_global_execution.factory.interactive_job_executor ska_src_api_global_execution.factory.panda_batch_job_executor ska_src_api_global_execution.job_submission ska_src_api_global_execution.job_submission.panda ska_src_api_global_execution.models ska_src_api_global_execution.models.config ska_src_api_global_execution.models.constants ska_src_api_global_execution.models.execution_model ska_src_api_global_execution.models.response ska_src_api_global_execution.models.workstep ska_src_api_global_execution.service ska_src_api_global_execution.service.broker_service ska_src_api_global_execution.service.execution_broker ska_src_api_global_execution.service.execution_service ska_src_api_global_execution.service.queue_service ska_src_api_global_execution.service.user_service ska_src_api_global_execution.service.utils ska_src_api_global_execution.session ska_src_api_global_execution.session.data_management_api_oauth2_session ska_src_api_global_execution.session.session ska_src_api_global_execution.session.site_capabilities_api_oauth2_session status utility workstep

MongoId (in module ska_src_api_global_execution.models.execution_model)

N

namespace (ska_src_api_global_execution.models.config.PandaJobDeploymentConfig attribute) node_selector (ska_src_api_global_execution.models.config.PandaJobDeploymentConfig attribute)

number_of_managed_requests (ska_src_api_global_execution.models.HealthResponse attribute) (ska_src_api_global_execution.models.response.HealthResponse attribute)

O

oauth2_service_token module oauth2_service_token_factory module OAuth2ServiceToken (class in oauth2_service_token)

OAuth2ServiceTokenFactory (class in oauth2_service_token_factory) openapi module oper_docs() (in module docs) output_data (ska_src_api_global_execution.models.workstep.WorkStepModelV1 attribute) outputs (ska_src_api_global_execution.models.workstep.WorkStepModel attribute)

P

PANDA_AUTH_ID_TOKEN (in module ska_src_api_global_execution.models.constants) panda_batch_job_executor() (in module beans) panda_client module panda_job_deployment_config() (in module beans) PANDA_SERVER_CONNECTION_ERROR (ska_src_api_global_execution.models.execution_model.ExecutionErrorCode attribute) PandaBatchJobExecutor (class in ska_src_api_global_execution.factory.panda_batch_job_executor) PandaClient (class in panda_client) PandaJobDeploymentConfig (class in ska_src_api_global_execution.models.config) parameters (ska_src_api_global_execution.models.workstep.WorkStepModelV1 attribute) parameters_json (ska_src_api_global_execution.models.workstep.WorkStepModel attribute) paramx (ska_src_api_global_execution.models.workstep.SystemParameters attribute) parent_workstep_id (ska_src_api_global_execution.models.workstep.WorkStepModel attribute) permission_api_health() (in module status) PermissionDenied Permissions (class in dependencies)

permissions_api (ska_src_api_global_execution.models.HealthResponse.DependentServices attribute) (ska_src_api_global_execution.models.response.HealthResponse.DependentServices attribute) ping() (async_mongo_client.AsyncMongo method) (global_execution_client.GlobalExecutionClient method) (in module status) (redis.RedisCache method) PingResponse (class in ska_src_api_global_execution.models) (class in ska_src_api_global_execution.models.response) populate_workstep_with_panda_details() (panda_client.PandaClient static method) priority_class_name (ska_src_api_global_execution.models.config.PandaJobDeploymentConfig attribute) process_object() (config_client.ConfigClient method) progress (ska_src_api_global_execution.models.workstep.WorkStepModel attribute) provenance_json (ska_src_api_global_execution.models.workstep.WorkStepModel attribute) (ska_src_api_global_execution.models.workstep.WorkStepModelV1 attribute) ProvenanceJson (class in ska_src_api_global_execution.models.workstep) PyObjectId (in module ska_src_api_global_execution.models.execution_model)

Q

QUEUE_NOT_FOUND (ska_src_api_global_execution.models.execution_model.ExecutionErrorCode attribute)

queued (ska_src_api_global_execution.models.workstep.ExecutionState attribute) QueueService (class in ska_src_api_global_execution.service.queue_service)

R

random_id() (in module ska_src_api_global_execution.service.utils) redis module RedisCache (class in redis) refresh_token() (iam_client.IAMClient method) REFRESH_TOKEN_BUFFER_SECONDS (iam_client.IAMClient attribute) REFRESH_TOKEN_GRANT_TYPE (iam_client.IAMClient attribute) replace_many() (async_mongo_client.AsyncMongo method) replace_one() (async_mongo_client.AsyncMongo method) request_timeout_adapter module request_timeout_adapter() (in module beans) required_configmaps (ska_src_api_global_execution.models.config.PandaJobDeploymentConfig attribute)

required_secrets (ska_src_api_global_execution.models.config.PandaJobDeploymentConfig attribute) requires_gpu (ska_src_api_global_execution.models.workstep.SystemParameters attribute) (ska_src_api_global_execution.models.workstep.WorkStepModel attribute) resolve_placeholders() (config_client.ConfigClient method) resolve_resources_for_workstep() (ska_src_api_global_execution.service.execution_broker.ExecutionBroker method) resource_broker_service_provider() (in module beans) resource_limits (ska_src_api_global_execution.models.config.PandaJobDeploymentConfig attribute) ResourceNotFoundError Response (class in ska_src_api_global_execution.models.response) response_code (ska_src_api_global_execution.models.response.ExecutionSubmissionResponse attribute) response_text (ska_src_api_global_execution.models.response.ExecutionSubmissionResponse attribute) role (ska_src_api_global_execution.models.workstep.DataLocationModel attribute) running (ska_src_api_global_execution.models.workstep.ExecutionState attribute)

S

save_execution_data() (execution_repository.ExecutionRepository method) save_execution_id_to_user_set() (execution_repository.ExecutionRepository method) script_location (ska_src_api_global_execution.models.config.PandaJobDeploymentConfig attribute) security (in module workstep) security_context (ska_src_api_global_execution.models.config.PandaJobDeploymentConfig attribute) send() (request_timeout_adapter.TimeoutHTTPAdapter method) server module service_account (ska_src_api_global_execution.models.config.PandaJobDeploymentConfig attribute) set_cache_token() (cache.Cache method) (redis.RedisCache method) setup_logging() (logger_client.LoggerClient static method) singleton module Singleton (class in singleton) SINGULARITY_JOB_TEMPLATE (panda_client.PandaClient attribute) site (ska_src_api_global_execution.models.workstep.WorkStepModel attribute) site_capabilities_api_health() (in module status) site_capabilities_client() (external_api_clients.ExternalApiClients method) site_capabilities_service_token module SiteCapabilitiesComputeClient (class in ska_src_api_global_execution.service.broker_service) SiteCapabilitiesServiceToken (class in site_capabilities_service_token) SiteCapabilitiesStorageClient (class in ska_src_api_global_execution.service.broker_service) ska_src_api_global_execution module ska_src_api_global_execution.factory module ska_src_api_global_execution.factory.batch_job_executor module ska_src_api_global_execution.factory.interactive_job_executor module ska_src_api_global_execution.factory.panda_batch_job_executor module ska_src_api_global_execution.job_submission module ska_src_api_global_execution.job_submission.panda module ska_src_api_global_execution.models module ska_src_api_global_execution.models.config module ska_src_api_global_execution.models.constants module ska_src_api_global_execution.models.execution_model module ska_src_api_global_execution.models.response module ska_src_api_global_execution.models.workstep module ska_src_api_global_execution.service module

ska_src_api_global_execution.service.broker_service module ska_src_api_global_execution.service.execution_broker module ska_src_api_global_execution.service.execution_service module ska_src_api_global_execution.service.queue_service module ska_src_api_global_execution.service.user_service module ska_src_api_global_execution.service.utils module ska_src_api_global_execution.session module ska_src_api_global_execution.session.data_management_api_oauth2_session module ska_src_api_global_execution.session.session module ska_src_api_global_execution.session.site_capabilities_api_oauth2_session module software_id (ska_src_api_global_execution.models.workstep.WorkStepModel attribute) source (ska_src_api_global_execution.models.workstep.ProvenanceJson attribute) src_node (ska_src_api_global_execution.models.workstep.SystemParameters attribute) starlette_config() (in module beans) started_at (ska_src_api_global_execution.models.workstep.WorkStepModel attribute) (ska_src_api_global_execution.models.workstep.WorkStepModelV1 attribute) state (ska_src_api_global_execution.models.workstep.WorkStepModel attribute) (ska_src_api_global_execution.models.workstep.WorkStepModelV1 attribute) static_path (in module server) status module status (ska_src_api_global_execution.models.HealthResponse.DependentServices.DependentServiceStatus attribute) (ska_src_api_global_execution.models.PingResponse attribute) (ska_src_api_global_execution.models.response.HealthResponse.DependentServices.DependentServiceStatus attribute) (ska_src_api_global_execution.models.response.PingResponse attribute) status_router (in module status) str_to_bool() (in module ska_src_api_global_execution.service.utils) str_to_int() (in module ska_src_api_global_execution.service.utils) str_to_int_without_default() (in module ska_src_api_global_execution.service.utils) submit() (in module workstep) (ska_src_api_global_execution.factory.batch_job_executor.BatchJobExecutor method) (ska_src_api_global_execution.factory.batch_job_executor.TestBatchJobExecutor method) (ska_src_api_global_execution.factory.interactive_job_executor.InteractiveJobExecutor method) (ska_src_api_global_execution.factory.panda_batch_job_executor.PandaBatchJobExecutor method) (ska_src_api_global_execution.service.execution_service.ExecutionService method) submit_job() (global_execution_client.GlobalExecutionClient method) submit_panda_job() (kubernetes.Kubernetes method) submit_task() (panda_client.PandaClient method) successful (ska_src_api_global_execution.models.GenericOperationResponse attribute) (ska_src_api_global_execution.models.response.GenericOperationResponse attribute) system_parameters (ska_src_api_global_execution.models.workstep.WorkStepModelV1 attribute) SystemParameters (class in ska_src_api_global_execution.models.workstep)

T

T (in module async_mongo_client) test_batch_job_executor() (in module beans) test_connection() (panda_client.PandaClient method) (redis.RedisCache method) TestBatchJobExecutor (class in ska_src_api_global_execution.factory.batch_job_executor) TimeoutHTTPAdapter (class in request_timeout_adapter)

TOKEN_CACHE_TTL_SECONDS (iam_client.IAMClient attribute) TOKEN_EXCHANGE_GRANT_TYPE (iam_client.IAMClient attribute) tolerations (ska_src_api_global_execution.models.config.PandaJobDeploymentConfig attribute) total_cpu() (panda_client.PandaClient static method) total_memory() (panda_client.PandaClient static method) ttl_seconds_after_finished (ska_src_api_global_execution.models.config.PandaJobDeploymentConfig attribute)

U

UNKNOWN_ERROR (ska_src_api_global_execution.models.execution_model.ExecutionErrorCode attribute) update_cache_with_token_response() (iam_client.IAMClient method) update_many() (async_mongo_client.AsyncMongo method) update_one() (async_mongo_client.AsyncMongo method) upsert_one() (async_mongo_client.AsyncMongo method) uptime (ska_src_api_global_execution.models.HealthResponse attribute) (ska_src_api_global_execution.models.response.HealthResponse attribute) uri (ska_src_api_global_execution.models.workstep.DataLocationModel attribute)

USER_ACCESS_TOKEN (in module ska_src_api_global_execution.models.constants) user_docs() (in module docs) USER_NAME (in module ska_src_api_global_execution.models.constants) user_name_from_token() (ska_src_api_global_execution.service.user_service.UserService static method) USER_TO_EXECUTION_IDS_TEMPLATE (execution_repository.ExecutionRepository attribute) UserService (class in ska_src_api_global_execution.service.user_service) utility module

V

verify_permission_for_service_route() (dependencies.Permissions method) version (ska_src_api_global_execution.models.PingResponse attribute) (ska_src_api_global_execution.models.response.PingResponse attribute)

versions (in module server)

W

walltime_minutes (ska_src_api_global_execution.models.workstep.WorkStepModel attribute) workflow_id (ska_src_api_global_execution.models.workstep.WorkStepModel attribute) (ska_src_api_global_execution.models.workstep.WorkStepModelV1 attribute) workstep module

workstep (ska_src_api_global_execution.models.execution_model.ExecutionModel attribute) workstep_id (ska_src_api_global_execution.models.workstep.DataLocationModel attribute) workstep_router (in module workstep) WorkStepModel (class in ska_src_api_global_execution.models.workstep) WorkStepModelV1 (class in ska_src_api_global_execution.models.workstep)