aind_behavior_experiment_launcher.data_transfer.watchdog_service.WatchdogDataTransferService

class aind_behavior_experiment_launcher.data_transfer.watchdog_service.WatchdogDataTransferService(source: PathLike, destination: PathLike, aind_session_data_mapper: AindDataSchemaSessionDataMapper | None = None, schedule_time: time | None = datetime.time(20, 0), project_name: str | None = None, platform: Platform = _Behavior(name='Behavior platform', abbreviation='behavior'), capsule_id: str | None = None, script: Dict[str, List[str]] | None = None, s3_bucket: BucketType = BucketType.PRIVATE, mount: str | None = None, force_cloud_sync: bool = True, transfer_endpoint: str = 'http://aind-data-transfer-service/api/v1/submit_jobs', validate: bool = True, session_name: str | None = None)

Bases: DataTransferService

__init__(source: PathLike, destination: PathLike, aind_session_data_mapper: AindDataSchemaSessionDataMapper | None = None, schedule_time: time | None = datetime.time(20, 0), project_name: str | None = None, platform: Platform = _Behavior(name='Behavior platform', abbreviation='behavior'), capsule_id: str | None = None, script: Dict[str, List[str]] | None = None, s3_bucket: BucketType = BucketType.PRIVATE, mount: str | None = None, force_cloud_sync: bool = True, transfer_endpoint: str = 'http://aind-data-transfer-service/api/v1/submit_jobs', validate: bool = True, session_name: str | None = None) → None

Methods

__init__(source, destination[, ...])
create_manifest_config_from_ads_session(...)	Create a ManifestConfig object
create_watch_config(watched_directory, ...)	Create a WatchConfig object
dump_manifest_config([path, make_dir])
force_restart([kill_if_running])
is_running()
is_valid_project_name()
transfer()
validate([create_config])

Attributes

aind_session_data_mapper

create_manifest_config_from_ads_session(ads_session: Session, ads_schemas: List[PathLike] | None = None, session_name: str | None = None) → ManifestConfig

Create a ManifestConfig object

static create_watch_config(watched_directory: PathLike, manifest_complete_directory: PathLike, webhook_url: str | None = None, create_dir: bool = True) → WatchConfig

Create a WatchConfig object