Index

A

ack() (automation_file.core.action_queue.ActionQueue method) acquire() (automation_file.core.file_lock.FileLock method) (automation_file.core.rate_limit.RateLimiter method) (automation_file.core.sqlite_lock.SQLiteLock method) action (automation_file.core.action_queue.QueueItem attribute) ActionQueue (class in automation_file.core.action_queue) ActionRegistry (class in automation_file.core.action_registry) add_package_to_executor() (automation_file.core.package_loader.PackageLoader method) AddCommandException ArchiveException ArgparseException attempts (automation_file.core.action_queue.QueueItem attribute) AuditException AuditLog (class in automation_file.core.audit) automation_file.client.http_client module automation_file.core.action_queue module automation_file.core.action_registry module automation_file.core.audit module automation_file.core.callback_executor module automation_file.core.checksum module automation_file.core.circuit_breaker module automation_file.core.content_store module automation_file.core.file_lock module automation_file.core.json_store module automation_file.core.manifest module automation_file.core.package_loader module automation_file.core.plugins module automation_file.core.progress module, [1] automation_file.core.quota module automation_file.core.rate_limit module

automation_file.core.retry module automation_file.core.secrets module automation_file.core.sqlite_lock module automation_file.core.substitution module automation_file.exceptions module automation_file.logging_config module automation_file.remote.azure_blob.delete_ops module automation_file.remote.cross_backend module automation_file.remote.dropbox_api.delete_ops module automation_file.remote.fsspec_bridge module automation_file.remote.ftp.delete_ops module automation_file.remote.google_drive.client module automation_file.remote.google_drive.delete_ops module automation_file.remote.google_drive.download_ops module automation_file.remote.google_drive.folder_ops module automation_file.remote.google_drive.search_ops module automation_file.remote.google_drive.share_ops module automation_file.remote.google_drive.upload_ops module automation_file.remote.http_download module automation_file.remote.s3.delete_ops module automation_file.remote.sftp.delete_ops module automation_file.remote.smb.client module automation_file.remote.url_validator module azure_blob_delete_blob() (in module automation_file.remote.azure_blob.delete_ops)

B

base_url (automation_file.client.http_client.HTTPActionClient property)

BoxException build_default_registry() (in module automation_file.core.action_registry)

C

call() (automation_file.core.circuit_breaker.CircuitBreaker method) callback_function() (automation_file.core.callback_executor.CallbackExecutor method) CallbackExecutor (class in automation_file.core.callback_executor) CallbackExecutorException cancel() (automation_file.core.progress.CancellationToken method), [1] (automation_file.core.progress.ProgressRegistry method), [1] CancellationToken (class in automation_file.core.progress), [1] CancelledException, [1] capacity (automation_file.core.rate_limit.RateLimiter property) CASException ChainedSecretProvider (class in automation_file.core.secrets) check_size() (automation_file.core.quota.Quota method)

ChecksumMismatchException CircuitBreaker (class in automation_file.core.circuit_breaker) CircuitOpenException clear_finished() (automation_file.core.progress.ProgressRegistry method), [1] close() (automation_file.client.http_client.HTTPActionClient method) (automation_file.remote.smb.client.SMBClient method) ContentStore (class in automation_file.core.content_store) copy_between() (in module automation_file.remote.cross_backend) copy_to() (automation_file.core.content_store.ContentStore method) count() (automation_file.core.audit.AuditLog method) create() (automation_file.core.progress.ProgressRegistry method), [1] CrossBackendException

D

DagException DataOpsException dead_letters() (automation_file.core.action_queue.ActionQueue method) default_provider() (in module automation_file.core.secrets) delete() (automation_file.core.content_store.ContentStore method) (automation_file.remote.smb.client.SMBClient method) dequeue() (automation_file.core.action_queue.ActionQueue method) DiffException DirNotExistsException download() (automation_file.remote.smb.client.SMBClient method) download_file() (in module automation_file.remote.http_download) drive_add_folder() (in module automation_file.remote.google_drive.folder_ops) drive_delete_file() (in module automation_file.remote.google_drive.delete_ops)

drive_download_file() (in module automation_file.remote.google_drive.download_ops) drive_download_file_from_folder() (in module automation_file.remote.google_drive.download_ops) drive_search_all_file() (in module automation_file.remote.google_drive.search_ops) drive_search_field() (in module automation_file.remote.google_drive.search_ops) drive_search_file_mimetype() (in module automation_file.remote.google_drive.search_ops) drive_share_file_to_anyone() (in module automation_file.remote.google_drive.share_ops) drive_share_file_to_domain() (in module automation_file.remote.google_drive.share_ops) drive_share_file_to_user() (in module automation_file.remote.google_drive.share_ops) drive_upload_dir_to_drive() (in module automation_file.remote.google_drive.upload_ops) drive_upload_dir_to_folder() (in module automation_file.remote.google_drive.upload_ops) drive_upload_to_drive() (in module automation_file.remote.google_drive.upload_ops) drive_upload_to_folder() (in module automation_file.remote.google_drive.upload_ops) dropbox_delete_path() (in module automation_file.remote.dropbox_api.delete_ops)

E

enqueue() (automation_file.core.action_queue.ActionQueue method) enqueued_at (automation_file.core.action_queue.QueueItem attribute) EnvSecretProvider (class in automation_file.core.secrets) event_dict (automation_file.core.action_registry.ActionRegistry property)

execute() (automation_file.client.http_client.HTTPActionClient method) ExecuteActionException exists() (automation_file.core.content_store.ContentStore method) (automation_file.remote.smb.client.SMBClient method)

F

file_checksum() (in module automation_file.core.checksum) FileAutomationException FileLock (class in automation_file.core.file_lock) FileNotExistsException FileSecretProvider (class in automation_file.core.secrets) finish() (automation_file.core.progress.ProgressReporter method), [1] finished_at (automation_file.core.progress.ProgressReporter attribute), [1] forget() (automation_file.core.progress.ProgressRegistry method), [1]

fsspec_delete() (in module automation_file.remote.fsspec_bridge) fsspec_download() (in module automation_file.remote.fsspec_bridge) fsspec_exists() (in module automation_file.remote.fsspec_bridge) fsspec_list_dir() (in module automation_file.remote.fsspec_bridge) fsspec_mkdir() (in module automation_file.remote.fsspec_bridge) fsspec_upload() (in module automation_file.remote.fsspec_bridge) FsspecEntry (class in automation_file.remote.fsspec_bridge) FsspecException ftp_delete_path() (in module automation_file.remote.ftp.delete_ops)

G

get() (automation_file.core.secrets.ChainedSecretProvider method) (automation_file.core.secrets.EnvSecretProvider method) (automation_file.core.secrets.FileSecretProvider method) (automation_file.core.secrets.SecretProvider method)

get_fs() (in module automation_file.remote.fsspec_bridge) GoogleDriveClient (class in automation_file.remote.google_drive.client)

H

HTTPActionClient (class in automation_file.client.http_client)

HTTPActionClientException

I

id (automation_file.core.action_queue.QueueItem attribute) is_cancelled (automation_file.core.progress.CancellationToken property), [1] is_dir (automation_file.remote.fsspec_bridge.FsspecEntry attribute) (automation_file.remote.smb.client.SMBEntry attribute)

is_finished (automation_file.core.progress.ProgressReporter property), [1] is_held (automation_file.core.file_lock.FileLock property) (automation_file.core.sqlite_lock.SQLiteLock property) iter_digests() (automation_file.core.content_store.ContentStore method)

J

JsonActionException

L

later_init() (automation_file.remote.google_drive.client.GoogleDriveClient method) list() (automation_file.core.progress.ProgressRegistry method), [1] list_dir() (automation_file.remote.smb.client.SMBClient method)

load() (automation_file.core.package_loader.PackageLoader method) load_entry_point_plugins() (in module automation_file.core.plugins) LockTimeoutException lookup() (automation_file.core.progress.ProgressRegistry method), [1]

M

ManifestException max_bytes (automation_file.core.quota.Quota attribute) max_seconds (automation_file.core.quota.Quota attribute) MCPServerException mkdir() (automation_file.remote.smb.client.SMBClient method) module automation_file.client.http_client automation_file.core.action_queue automation_file.core.action_registry automation_file.core.audit automation_file.core.callback_executor automation_file.core.checksum automation_file.core.circuit_breaker automation_file.core.content_store automation_file.core.file_lock automation_file.core.json_store automation_file.core.manifest automation_file.core.package_loader automation_file.core.plugins automation_file.core.progress, [1] automation_file.core.quota automation_file.core.rate_limit automation_file.core.retry automation_file.core.secrets automation_file.core.sqlite_lock automation_file.core.substitution automation_file.exceptions automation_file.logging_config automation_file.remote.azure_blob.delete_ops automation_file.remote.cross_backend automation_file.remote.dropbox_api.delete_ops automation_file.remote.fsspec_bridge automation_file.remote.ftp.delete_ops automation_file.remote.google_drive.client automation_file.remote.google_drive.delete_ops automation_file.remote.google_drive.download_ops automation_file.remote.google_drive.folder_ops automation_file.remote.google_drive.search_ops automation_file.remote.google_drive.share_ops automation_file.remote.google_drive.upload_ops automation_file.remote.http_download automation_file.remote.s3.delete_ops automation_file.remote.sftp.delete_ops automation_file.remote.smb.client automation_file.remote.url_validator

N

nack() (automation_file.core.action_queue.ActionQueue method) name (automation_file.core.progress.ProgressReporter attribute), [1] (automation_file.remote.fsspec_bridge.FsspecEntry attribute) (automation_file.remote.smb.client.SMBEntry attribute)

names() (automation_file.core.action_registry.ActionRegistry method)

O

OneDriveException

open() (automation_file.core.content_store.ContentStore method) owner (automation_file.core.sqlite_lock.SQLiteLock property)

P

PackageLoader (class in automation_file.core.package_loader) path (automation_file.core.file_lock.FileLock property) path_for() (automation_file.core.content_store.ContentStore method) PathTraversalException ping() (automation_file.client.http_client.HTTPActionClient method) progress_cancel() (in module automation_file.core.progress), [1] progress_clear() (in module automation_file.core.progress), [1]

progress_list() (in module automation_file.core.progress), [1] ProgressRegistry (class in automation_file.core.progress), [1] ProgressReporter (class in automation_file.core.progress), [1] purge() (automation_file.core.action_queue.ActionQueue method) (automation_file.core.audit.AuditLog method) put() (automation_file.core.content_store.ContentStore method) put_bytes() (automation_file.core.content_store.ContentStore method)

Q

QueueException QueueItem (class in automation_file.core.action_queue)

Quota (class in automation_file.core.quota) QuotaExceededException

R

raise_if_cancelled() (automation_file.core.progress.CancellationToken method), [1] RateLimiter (class in automation_file.core.rate_limit) RateLimitExceededException read_action_json() (in module automation_file.core.json_store) recent() (automation_file.core.audit.AuditLog method) record() (automation_file.core.audit.AuditLog method) refresh() (automation_file.core.sqlite_lock.SQLiteLock method) register() (automation_file.core.action_registry.ActionRegistry method) register_many() (automation_file.core.action_registry.ActionRegistry method) register_progress_ops() (in module automation_file.core.progress), [1]

release() (automation_file.core.file_lock.FileLock method) (automation_file.core.sqlite_lock.SQLiteLock method) require_service() (automation_file.remote.google_drive.client.GoogleDriveClient method) reset() (automation_file.core.circuit_breaker.CircuitBreaker method) resolve() (automation_file.core.action_registry.ActionRegistry method) resolve_one() (automation_file.core.secrets.ChainedSecretProvider method) resolve_secret_refs() (in module automation_file.core.secrets) retry_on_transient() (in module automation_file.core.retry) RetryExhaustedException rmdir() (automation_file.remote.smb.client.SMBClient method) root (automation_file.core.content_store.ContentStore property)

S

s3_delete_object() (in module automation_file.remote.s3.delete_ops) scheme (automation_file.core.secrets.ChainedSecretProvider attribute) (automation_file.core.secrets.EnvSecretProvider attribute) (automation_file.core.secrets.FileSecretProvider attribute) (automation_file.core.secrets.SecretProvider attribute) SecretException SecretNotFoundException SecretProvider (class in automation_file.core.secrets) sftp_delete_path() (in module automation_file.remote.sftp.delete_ops) size (automation_file.remote.fsspec_bridge.FsspecEntry attribute) (automation_file.remote.smb.client.SMBEntry attribute)

size() (automation_file.core.action_queue.ActionQueue method) (automation_file.core.content_store.ContentStore method) SMBClient (class in automation_file.remote.smb.client) SMBEntry (class in automation_file.remote.smb.client) SMBException snapshot() (automation_file.core.progress.ProgressReporter method), [1] SQLiteLock (class in automation_file.core.sqlite_lock) started_at (automation_file.core.progress.ProgressReporter attribute), [1] state (automation_file.core.circuit_breaker.CircuitBreaker property) status (automation_file.core.progress.ProgressReporter attribute), [1] substitute() (in module automation_file.core.substitution) SubstitutionException

T

TCPAuthException TemplateException TextOpsException time_budget() (automation_file.core.quota.Quota method)

total (automation_file.core.progress.ProgressReporter attribute), [1] TracingException transferred (automation_file.core.progress.ProgressReporter attribute), [1] try_acquire() (automation_file.core.rate_limit.RateLimiter method)

U

unregister() (automation_file.core.action_registry.ActionRegistry method) update() (automation_file.core.action_registry.ActionRegistry method) (automation_file.core.progress.ProgressReporter method), [1]

upload() (automation_file.remote.smb.client.SMBClient method) UrlValidationException

V

validate_http_url() (in module automation_file.remote.url_validator) ValidationException

verify_checksum() (in module automation_file.core.checksum) verify_manifest() (in module automation_file.core.manifest) VersioningException

W

WebDAVException wraps() (automation_file.core.circuit_breaker.CircuitBreaker method) (automation_file.core.quota.Quota method) (automation_file.core.rate_limit.RateLimiter method)

write_action_json() (in module automation_file.core.json_store) write_manifest() (in module automation_file.core.manifest)

Z

ZipInputException