calypso.dispatchers.orchestrator.executor.base_executor module

class calypso.dispatchers.orchestrator.executor.base_executor.BaseExecutor(name='local', **kwargs)

Bases: object

abstractmethod download_job(job_dict)

abstractmethod download_remote_file(remote_file_name, local_file_name)

abstractmethod execute(command, timeout=3600, log_file=None) → ProcInfo

return output, error and code.

Parameters:: command (_type_) – _description_
Returns:: _description_
Return type:: _type_

abstractmethod files_exist(local_path, filenames)

abstractmethod get_remote_file_obj(remote_file_name, mode='r')

abstractmethod locally_rglob(remote_dir, pattern)

abstractmethod make_remote_dir(remote_dir_name)

abstractmethod read_remote_file(remote_file_name)

abstractmethod rglob(remote_dir, pattern)

abstractmethod upload_file_to_remote(local_filename, remote_filename)

abstractmethod upload_job(job: Job)

abstractmethod write_into_remote_file(data, remote_file_name)