Index

A

ABOVE_NORMAL (agiparallel.constants.JobPriority attribute) activity (agiparallel.infrastructure.AgentSnapshot.AgentSnapshot attribute) add_dependency() (agiparallel.client.Job method) add_task() (agiparallel.client.Job method) add_task_preconditions() (agiparallel.client.Job method) additional_id (agiparallel.infrastructure.TaskEnvironmentIdentification.TaskEnvironmentIdentification attribute) additional_information (agiparallel.infrastructure.TaskProgressInformation.TaskProgressInformation attribute) agent_selection_preference (agiparallel.client.Job attribute) (agiparallel.infrastructure.TaskState.TaskState attribute) AgentSelectionType (class in agiparallel.constants) AgentSnapshot (class in agiparallel.infrastructure.AgentSnapshot) agiparallel.client module agiparallel.constants module agiparallel.infrastructure.AgentSnapshot module agiparallel.infrastructure.ConsumableResourceRange module agiparallel.infrastructure.HardDiskStatus module agiparallel.infrastructure.HostRecycleSettings module agiparallel.infrastructure.NetworkStatus module agiparallel.infrastructure.TaskEnvironment module agiparallel.infrastructure.TaskEnvironmentDefinition module agiparallel.infrastructure.TaskEnvironmentIdentification module agiparallel.infrastructure.TaskEnvironmentMetadata module agiparallel.infrastructure.TaskMetadata module agiparallel.infrastructure.TaskPrecondition module agiparallel.infrastructure.TaskProgressInformation module agiparallel.infrastructure.TaskState module allocated_task_resources (agiparallel.infrastructure.TaskState.TaskState attribute) ancestors (agiparallel.infrastructure.TaskState.TaskState attribute) ANY (agiparallel.constants.CpuArchitecture attribute) ASSIGNED (agiparallel.constants.TaskStatus attribute) assigned_worker (agiparallel.infrastructure.TaskState.TaskState attribute) AVAILABLE_CORES (agiparallel.constants.CommonResources attribute) AVAILABLE_HARD_DISK (agiparallel.constants.CommonResources attribute) AVAILABLE_MEMORY (agiparallel.constants.CommonResources attribute)

B

BATCH (agiparallel.constants.ExecutionModeType attribute) BELOW_NORMAL (agiparallel.constants.JobPriority attribute)

C

cancel() (agiparallel.client.Job method) (agiparallel.client.JobDispatcher method) cancel_job() (agiparallel.client.ClusterJobScheduler method) (agiparallel.client.CoordinatorProxy method) cancel_on_client_disconnection (agiparallel.client.Job attribute) cancel_on_task_failure (agiparallel.client.Job attribute) CANCEL_TASK (agiparallel.constants.CoordinatorCommand attribute) cancel_task() (agiparallel.client.ClusterJobScheduler method) CANCELED (agiparallel.constants.TaskStatus attribute) CANCELING (agiparallel.constants.TaskStatus attribute) cancellation_message (agiparallel.infrastructure.TaskState.TaskState attribute) cancellation_reason (agiparallel.infrastructure.TaskState.TaskState attribute) capacity (agiparallel.infrastructure.AgentSnapshot.AgentSnapshot attribute) CHANGE_AGENT_PRIORITY (agiparallel.constants.CoordinatorCommand attribute) CLEAR_LOG (agiparallel.constants.CoordinatorCommand attribute) ClusterJobScheduler (class in agiparallel.client) ClusterJobSchedulerException CommonResources (class in agiparallel.constants) COMPLETED (agiparallel.constants.TaskStatus attribute) configuration_content (agiparallel.infrastructure.TaskEnvironmentMetadata.TaskEnvironmentMetadata attribute) connect() (agiparallel.client.ClusterJobScheduler method) CONSEQUENTIAL (agiparallel.constants.TaskCancellationReason attribute) ConsumableResourceRange (class in agiparallel.infrastructure.ConsumableResourceRange) ConsumableResources (class in agiparallel.constants) CoordinatorCommand (class in agiparallel.constants) CoordinatorProxy (class in agiparallel.client) CORES (agiparallel.constants.ConsumableResources attribute) cpu_speed (agiparallel.infrastructure.AgentSnapshot.AgentSnapshot attribute) CpuArchitecture (class in agiparallel.constants) create_job() (agiparallel.client.ClusterJobScheduler method) current_cpu_usage (agiparallel.infrastructure.AgentSnapshot.AgentSnapshot attribute) CURRENT_WORKLOAD (agiparallel.constants.CommonResources attribute)

D

date_assigned (agiparallel.infrastructure.TaskState.TaskState attribute) date_completed (agiparallel.infrastructure.TaskState.TaskState attribute) date_started (agiparallel.infrastructure.AgentSnapshot.AgentSnapshot attribute) (agiparallel.infrastructure.TaskState.TaskState attribute) date_submitted (agiparallel.infrastructure.TaskState.TaskState attribute) DEBUG (agiparallel.constants.LoggingLevel attribute) DEFAULT (agiparallel.constants.AgentSelectionType attribute) DefaultTaskEnvironment (class in agiparallel.client) dependencies (agiparallel.infrastructure.TaskEnvironmentMetadata.TaskEnvironmentMetadata attribute) description (agiparallel.client.Job attribute) (agiparallel.infrastructure.AgentSnapshot.AgentSnapshot attribute) DIRECT (agiparallel.constants.TaskCancellationReason attribute) DISABLE_AGENT (agiparallel.constants.CoordinatorCommand attribute) disable_sending_events (agiparallel.infrastructure.TaskState.TaskState attribute) disable_standard_output_redirect (agiparallel.infrastructure.TaskState.TaskState attribute) disconnect() (agiparallel.client.ClusterJobScheduler method) disconnected (agiparallel.client.CoordinatorProxy property) DOTNET (agiparallel.constants.TaskExecutionType attribute)

E

ENABLE_AGENT (agiparallel.constants.CoordinatorCommand attribute) ENVIRONMENT (agiparallel.constants.TaskProperties attribute) ENVIRONMENT_ERROR (agiparallel.constants.TaskStatus attribute) environment_identification (agiparallel.infrastructure.TaskState.TaskState attribute) EQUAL_TO (agiparallel.constants.Operator attribute) ERROR (agiparallel.constants.LoggingLevel attribute) ESTIMATED_MEMORY_BUDGET (agiparallel.constants.ConsumableResources attribute) estimated_memory_budget (agiparallel.infrastructure.AgentSnapshot.AgentSnapshot attribute) EVENT_COORDINATOR_DISCONNECTED (agiparallel.client.JobDispatcher attribute) EVENT_COORDINATOR_LOST (agiparallel.client.JobDispatcher attribute) EVENT_JOB_CANCELED_HANDLE (agiparallel.client.JobDispatcher attribute) EVENT_PENDING_ALL_TASKS_DONE_HANDLE (agiparallel.client.JobDispatcher attribute) EVENT_PENDING_HANDLE (agiparallel.client.JobDispatcher attribute) execution_type (agiparallel.infrastructure.TaskEnvironmentIdentification.TaskEnvironmentIdentification attribute) (agiparallel.infrastructure.TaskState.TaskState attribute) ExecutionModeType (class in agiparallel.constants)

F

fail_if_preconditions_not_satisfied (agiparallel.infrastructure.TaskState.TaskState attribute) FAILED (agiparallel.constants.TaskStatus attribute) FATAL (agiparallel.constants.LoggingLevel attribute) fixed_number_of_tasks (agiparallel.infrastructure.HostRecycleSettings.HostRecycleSettings attribute) free_space (agiparallel.infrastructure.HardDiskStatus.HardDiskStatus attribute) FutureTaskResult (class in agiparallel.client)

G

get_coordinator_snapshot() (agiparallel.client.ClusterJobScheduler method) (agiparallel.client.CoordinatorProxy method) get_server_maximum_host_count() (agiparallel.client.ClusterJobScheduler method) get_task_name() (in module agiparallel.client) GRACEFUL_CANCELLATION_TIMEOUT (agiparallel.constants.TaskProperties attribute) GREATER_THAN (agiparallel.constants.Operator attribute) group_id (agiparallel.infrastructure.TaskState.TaskState attribute)

H

hard_disk (agiparallel.infrastructure.AgentSnapshot.AgentSnapshot attribute) HardDiskStatus (class in agiparallel.infrastructure.HardDiskStatus) headers (agiparallel.infrastructure.TaskEnvironmentDefinition.TaskEnvironmentDefinition attribute) HEARTBEAT_RESPONSE (agiparallel.constants.CoordinatorCommand attribute) HIGH (agiparallel.constants.JobPriority attribute) host_architecture (agiparallel.infrastructure.TaskEnvironment.TaskEnvironment attribute) (agiparallel.infrastructure.TaskEnvironmentIdentification.TaskEnvironmentIdentification attribute) HOST_END_TIME (agiparallel.constants.TaskProperties attribute) host_gc_mode (agiparallel.infrastructure.TaskEnvironmentIdentification.TaskEnvironmentIdentification attribute) host_id (agiparallel.infrastructure.TaskState.TaskState attribute) host_pool (agiparallel.infrastructure.AgentSnapshot.AgentSnapshot attribute) HOST_START_TIME (agiparallel.constants.TaskProperties attribute) HOSTNAME (agiparallel.constants.CommonResources attribute) HostRecycleSettings (class in agiparallel.infrastructure.HostRecycleSettings)

I

id (agiparallel.client.ClusterJobScheduler property) (agiparallel.infrastructure.AgentSnapshot.AgentSnapshot attribute) identification (agiparallel.infrastructure.TaskEnvironmentDefinition.TaskEnvironmentDefinition attribute) (agiparallel.infrastructure.TaskEnvironmentMetadata.TaskEnvironmentMetadata attribute) idle_timeout (agiparallel.infrastructure.HostRecycleSettings.HostRecycleSettings attribute) INFO (agiparallel.constants.LoggingLevel attribute) InfrastructureException INTERACTIVE (agiparallel.constants.ExecutionModeType attribute) INTERRUPTED (agiparallel.constants.TaskStatus attribute) INTERRUPTED_RETRY_ATTEMPTS (agiparallel.constants.TaskProperties attribute) interrupted_retry_attempts_so_far (agiparallel.infrastructure.TaskState.TaskState attribute) IS_64BIT_PROCESS (agiparallel.constants.CommonResources attribute) is_connected() (agiparallel.client.ClusterJobScheduler method) is_enabled (agiparallel.infrastructure.AgentSnapshot.AgentSnapshot attribute) is_exclusive (agiparallel.infrastructure.TaskState.TaskState attribute) is_registered (agiparallel.infrastructure.AgentSnapshot.AgentSnapshot attribute)

J

Job (class in agiparallel.client) job_completion (agiparallel.infrastructure.HostRecycleSettings.HostRecycleSettings attribute) JOB_SCHEDULER_CONTEXT (agiparallel.constants.TaskProperties attribute) JobDispatcher (class in agiparallel.client) JobPriority (class in agiparallel.constants) join() (agiparallel.client.FutureTaskResult method)

L

last_error_message (agiparallel.client.CoordinatorProxy property) last_interrupt_reason (agiparallel.infrastructure.TaskState.TaskState attribute) LEAST_RECENTLY_SELECTED (agiparallel.constants.AgentSelectionType attribute) LESS_THAN (agiparallel.constants.Operator attribute) LICENSE_INFO (agiparallel.constants.CoordinatorCommand attribute) link_bandwidth (agiparallel.infrastructure.NetworkStatus.NetworkStatus attribute) LINUX (agiparallel.constants.OSPlatform attribute) LOGGER (agiparallel.constants.TaskProperties attribute) logging_level (agiparallel.infrastructure.AgentSnapshot.AgentSnapshot attribute) LoggingLevel (class in agiparallel.constants) LOW (agiparallel.constants.JobPriority attribute)

M

machine_name (agiparallel.infrastructure.AgentSnapshot.AgentSnapshot attribute) mailbox_acquaintances (agiparallel.infrastructure.TaskState.TaskState attribute) max_interrupted_retry_attempts (agiparallel.client.Job attribute) (agiparallel.infrastructure.TaskState.TaskState attribute) max_value (agiparallel.infrastructure.ConsumableResourceRange.ConsumableResourceRange attribute) meets_threshold (agiparallel.infrastructure.AgentSnapshot.AgentSnapshot attribute) MEMBER_OF (agiparallel.constants.Operator attribute) MEMORY (agiparallel.constants.ConsumableResources attribute) memory (agiparallel.infrastructure.AgentSnapshot.AgentSnapshot attribute) min_value (agiparallel.infrastructure.ConsumableResourceRange.ConsumableResourceRange attribute) module agiparallel.client agiparallel.constants agiparallel.infrastructure.AgentSnapshot agiparallel.infrastructure.ConsumableResourceRange agiparallel.infrastructure.HardDiskStatus agiparallel.infrastructure.HostRecycleSettings agiparallel.infrastructure.NetworkStatus agiparallel.infrastructure.TaskEnvironment agiparallel.infrastructure.TaskEnvironmentDefinition agiparallel.infrastructure.TaskEnvironmentIdentification agiparallel.infrastructure.TaskEnvironmentMetadata agiparallel.infrastructure.TaskMetadata agiparallel.infrastructure.TaskPrecondition agiparallel.infrastructure.TaskProgressInformation agiparallel.infrastructure.TaskState MOST_RECENTLY_SELECTED (agiparallel.constants.AgentSelectionType attribute)

N

name (agiparallel.client.Job attribute) (agiparallel.infrastructure.TaskEnvironmentDefinition.TaskEnvironmentDefinition attribute) (agiparallel.infrastructure.TaskEnvironmentMetadata.TaskEnvironmentMetadata attribute) network (agiparallel.infrastructure.AgentSnapshot.AgentSnapshot attribute) NetworkStatus (class in agiparallel.infrastructure.NetworkStatus) NONE (agiparallel.constants.TaskCancellationReason attribute) NORMAL (agiparallel.constants.JobPriority attribute) NOT_EQUAL_TO (agiparallel.constants.Operator attribute) NOT_SUBMITTED (agiparallel.constants.TaskStatus attribute) NOTHING (agiparallel.constants.CoordinatorCommand attribute)

O

on_coordinator_disconnected() (agiparallel.client.ClusterJobScheduler method) (agiparallel.client.JobDispatcher method) on_coordinator_lost() (agiparallel.client.JobDispatcher method) operation (agiparallel.infrastructure.TaskPrecondition.TaskPrecondition attribute) Operator (class in agiparallel.constants) OS_PLATFORM (agiparallel.constants.CommonResources attribute) os_platform (agiparallel.infrastructure.AgentSnapshot.AgentSnapshot attribute) OSPlatform (class in agiparallel.constants)

P

payload (agiparallel.infrastructure.TaskEnvironmentMetadata.TaskEnvironmentMetadata attribute) POLL (agiparallel.constants.CoordinatorCommand attribute) priority (agiparallel.client.Job attribute) PRIORITY (agiparallel.constants.AgentSelectionType attribute) priority (agiparallel.infrastructure.AgentSnapshot.AgentSnapshot attribute) (agiparallel.infrastructure.TaskState.TaskState attribute) private_memory_usage_maximum (agiparallel.infrastructure.HostRecycleSettings.HostRecycleSettings attribute) process_id (agiparallel.infrastructure.TaskState.TaskState attribute) progress (agiparallel.infrastructure.TaskProgressInformation.TaskProgressInformation attribute) properties_payload (agiparallel.infrastructure.TaskMetadata.TaskMetadata attribute) PYTHON (agiparallel.constants.TaskExecutionType attribute)

R

RANDOM (agiparallel.constants.AgentSelectionType attribute) receive_rate (agiparallel.infrastructure.NetworkStatus.NetworkStatus attribute) reconnect() (agiparallel.client.ClusterJobScheduler method) recycle_id (agiparallel.infrastructure.TaskEnvironmentIdentification.TaskEnvironmentIdentification attribute) recycle_settings (agiparallel.infrastructure.TaskEnvironment.TaskEnvironment attribute) (agiparallel.infrastructure.TaskEnvironmentMetadata.TaskEnvironmentMetadata attribute) regular_interval (agiparallel.infrastructure.HostRecycleSettings.HostRecycleSettings attribute) REQUEST_LOG (agiparallel.constants.CoordinatorCommand attribute) requested_task_resources (agiparallel.infrastructure.TaskState.TaskState attribute) required_license (agiparallel.infrastructure.TaskEnvironmentDefinition.TaskEnvironmentDefinition attribute) (agiparallel.infrastructure.TaskEnvironmentMetadata.TaskEnvironmentMetadata attribute) (agiparallel.infrastructure.TaskState.TaskState attribute) resource (agiparallel.infrastructure.TaskPrecondition.TaskPrecondition attribute) resource_value (agiparallel.infrastructure.TaskPrecondition.TaskPrecondition attribute) resources (agiparallel.infrastructure.AgentSnapshot.AgentSnapshot attribute) restart() (agiparallel.client.CoordinatorProxy method) result_payload (agiparallel.infrastructure.TaskMetadata.TaskMetadata attribute) RUNNING (agiparallel.constants.TaskStatus attribute) runtime_properties (agiparallel.infrastructure.AgentSnapshot.AgentSnapshot attribute)

S

send_rate (agiparallel.infrastructure.NetworkStatus.NetworkStatus attribute) set_task_environment() (agiparallel.client.Job method) setup() (agiparallel.client.DefaultTaskEnvironment method) (agiparallel.infrastructure.TaskEnvironment.TaskEnvironment method) specific_times (agiparallel.infrastructure.HostRecycleSettings.HostRecycleSettings attribute) standard_error (agiparallel.infrastructure.TaskState.TaskState attribute) standard_output (agiparallel.infrastructure.TaskState.TaskState attribute) start() (agiparallel.client.CoordinatorProxy method) state (agiparallel.infrastructure.TaskMetadata.TaskMetadata attribute) status (agiparallel.infrastructure.TaskState.TaskState attribute) stop() (agiparallel.client.CoordinatorProxy method) submit() (agiparallel.client.Job method) (agiparallel.client.JobDispatcher method) (in module agiparallel.client) submit_job() (agiparallel.client.ClusterJobScheduler method) (agiparallel.client.CoordinatorProxy method) SUBMITTED (agiparallel.constants.TaskStatus attribute) submitter (agiparallel.infrastructure.TaskState.TaskState attribute) SUBMITTER_ID (agiparallel.constants.TaskProperties attribute) submitter_id (agiparallel.infrastructure.TaskState.TaskState attribute) submitter_machine_name (agiparallel.infrastructure.TaskState.TaskState attribute) submitter_user_name (agiparallel.infrastructure.TaskState.TaskState attribute)

T

task (agiparallel.client.TaskCallbacksContext property) task_completed_callback (agiparallel.client.TaskCallbacksContext property) task_environment_no_longer_referenced (agiparallel.infrastructure.HostRecycleSettings.HostRecycleSettings attribute) task_execution_timeout (agiparallel.client.Job attribute) task_id (agiparallel.infrastructure.TaskState.TaskState attribute) task_name (agiparallel.infrastructure.TaskState.TaskState attribute) task_payload (agiparallel.infrastructure.TaskMetadata.TaskMetadata attribute) task_preconditions (agiparallel.client.Job attribute) (agiparallel.infrastructure.TaskState.TaskState attribute) task_progress_updated_callback (agiparallel.client.TaskCallbacksContext property) task_state_updated_callback (agiparallel.client.TaskCallbacksContext property) TaskCallbacksContext (class in agiparallel.client) TaskCancellationReason (class in agiparallel.constants) TaskEnvironment (class in agiparallel.infrastructure.TaskEnvironment) TaskEnvironmentDefinition (class in agiparallel.infrastructure.TaskEnvironmentDefinition) TaskEnvironmentIdentification (class in agiparallel.infrastructure.TaskEnvironmentIdentification) TaskEnvironmentMetadata (class in agiparallel.infrastructure.TaskEnvironmentMetadata) TaskExecutionType (class in agiparallel.constants) TaskMetadata (class in agiparallel.infrastructure.TaskMetadata) TaskPrecondition (class in agiparallel.infrastructure.TaskPrecondition) TaskProgressInformation (class in agiparallel.infrastructure.TaskProgressInformation) TaskProperties (class in agiparallel.constants) tasks_per_host (agiparallel.infrastructure.TaskEnvironment.TaskEnvironment property) TaskState (class in agiparallel.infrastructure.TaskState) TaskStatus (class in agiparallel.constants) TaskStatusChangedEventArgs (class in agiparallel.client) teardown() (agiparallel.client.DefaultTaskEnvironment method) (agiparallel.infrastructure.TaskEnvironment.TaskEnvironment method) teardown_timeout (agiparallel.infrastructure.TaskEnvironment.TaskEnvironment attribute) (agiparallel.infrastructure.TaskEnvironmentMetadata.TaskEnvironmentMetadata attribute) terminated_gracefully (agiparallel.client.CoordinatorProxy property) threshold_failure_reason (agiparallel.infrastructure.AgentSnapshot.AgentSnapshot attribute) time_stamp (agiparallel.infrastructure.AgentSnapshot.AgentSnapshot attribute) TIMED_OUT (agiparallel.constants.TaskStatus attribute) timeout (agiparallel.infrastructure.TaskState.TaskState attribute) TOTAL_CORES (agiparallel.constants.CommonResources attribute) total_space (agiparallel.infrastructure.HardDiskStatus.HardDiskStatus attribute)

U

unique_id (agiparallel.infrastructure.TaskEnvironment.TaskEnvironment attribute) (agiparallel.infrastructure.TaskEnvironmentIdentification.TaskEnvironmentIdentification attribute) (agiparallel.infrastructure.TaskState.TaskState attribute) UNSET (agiparallel.constants.TaskExecutionType attribute) UNSPECIFIED (agiparallel.constants.OSPlatform attribute) user_name (agiparallel.infrastructure.AgentSnapshot.AgentSnapshot attribute)

W

wait_until_done() (agiparallel.client.ClusterJobScheduler method) (agiparallel.client.Job method) (agiparallel.client.JobDispatcher method) WARN (agiparallel.constants.LoggingLevel attribute) WINDOWS (agiparallel.constants.OSPlatform attribute) working_directory (agiparallel.infrastructure.TaskEnvironmentMetadata.TaskEnvironmentMetadata attribute)

X

X64 (agiparallel.constants.CpuArchitecture attribute) X86 (agiparallel.constants.CpuArchitecture attribute)