orca.tasks.fortests =================== .. py:module:: orca.tasks.fortests .. autoapi-nested-parse:: Test and debugging tasks for Celery verification. Contains simple Celery tasks for testing worker functionality, task routing, and basic operations. These are not used in production pipelines. Functions --------- .. autoapisummary:: orca.tasks.fortests.add orca.tasks.fortests.str_concat orca.tasks.fortests.pcp orca.tasks.fortests.pcp_tree orca.tasks.fortests.read_ms orca.tasks.fortests.test_multiprocessing orca.tasks.fortests.do_sum Module Contents --------------- .. py:function:: add(x: int, y: int) -> int Simple addition task for testing Celery connectivity. :param x: First integer. :param y: Second integer. :returns: Sum of x and y. .. py:function:: str_concat(first: str, second: str, third: str = '') -> str String concatenation task for testing. :param first: First string. :param second: Second string. :param third: Optional third string. :returns: Concatenated string. .. py:function:: pcp(source: str, target_dir: str) Copy a file to a target directory. :param source: Source file path. :param target_dir: Target directory path. .. py:function:: pcp_tree(source: str, target_dir: str) Copy a directory tree to a target location. :param source: Source directory path. :param target_dir: Target parent directory. .. py:function:: read_ms(ms: str, lock: bool) Test reading a measurement set. :param ms: Path to measurement set. :param lock: If True, open read-only. .. py:function:: test_multiprocessing() Test billiard multiprocessing in Celery workers. .. py:function:: do_sum(args) Sum a sequence of numbers. :param args: Iterable of numbers. :returns: Sum of the numbers.