pycompss_dummy

Author: Canicula98

src/dataclay/contrib/modeltest/compss.py

@@ -8,7 +8,7 @@
     from pycompss.api.parameter import CONCURRENT, INOUT
     from pycompss.api.task import task
 except ImportError:
-    from dataclay.contrib.dummy_pycompss import task, INOUT, CONCURRENT
+    from dataclay.contrib.pycompss_dummy.dummy_pycompss import task, INOUT, CONCURRENT
 
 from dataclay import DataClayObject, activemethod
 

src/dataclay/contrib/persistent_block.py

@@ -10,7 +10,7 @@
     from pycompss.api.task import task
     from pycompss.api.parameter import IN
 except ImportError:
-    from dataclay.contrib.dummy_pycompss import task, IN
+    from dataclay.contrib.pycompss_dummy.dummy_pycompss import task, IN
 
 
 class PersistentBlock(DataClayObject):

src/dataclay/contrib/pycompss_dummy/__init__.py

@@ -0,0 +1,20 @@
+#!/usr/bin/env python3
+#
+#  Copyright 2002-2026 Barcelona Supercomputing Center (www.bsc.es)
+#
+#  Licensed under the Apache License, Version 2.0 (the "License");
+#  you may not use this file except in compliance with the License.
+#  You may obtain a copy of the License at
+#
+#      http://www.apache.org/licenses/LICENSE-2.0
+#
+#  Unless required by applicable law or agreed to in writing, software
+#  distributed under the License is distributed on an "AS IS" BASIS,
+#  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+#  See the License for the specific language governing permissions and
+#  limitations under the License.
+#
+
+# -*- coding: utf-8 -*-
+
+"""This package contains the API dummy functions, constants and classes."""

src/dataclay/contrib/pycompss_dummy/_decorator.py

@@ -0,0 +1,59 @@
+#!/usr/bin/env python3
+#
+#  Copyright 2002-2026 Barcelona Supercomputing Center (www.bsc.es)
+#
+#  Licensed under the Apache License, Version 2.0 (the "License");
+#  you may not use this file except in compliance with the License.
+#  You may obtain a copy of the License at
+#
+#      http://www.apache.org/licenses/LICENSE-2.0
+#
+#  Unless required by applicable law or agreed to in writing, software
+#  distributed under the License is distributed on an "AS IS" BASIS,
+#  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+#  See the License for the specific language governing permissions and
+#  limitations under the License.
+#
+
+# -*- coding: utf-8 -*-
+
+"""
+PyCOMPSs API - dummy - decorator.
+
+This file contains the dummy class task used as decorator.
+"""
+
+from pycompss.util.typing_helper import typing
+
+
+class _Dummy:
+    """Dummy task class (decorator style)."""
+
+    def __init__(self, *args: typing.Any, **kwargs: typing.Any) -> None:
+        """Construct a dummy Task decorator.
+
+        :param args: Task decorator arguments.
+        :param kwargs: Task decorator keyword arguments.
+        :returns: None
+        """
+        self.args = args
+        self.kwargs = kwargs
+
+    def __call__(self, function: typing.Any) -> typing.Any:
+        """Invoke the dummy decorator.
+
+        :param function: Decorated function.
+        :returns: Result of executing the given function.
+        """
+
+        def wrapped_f(*args: typing.Any, **kwargs: typing.Any) -> typing.Any:
+            # returns may appear in @task decorator
+            if "returns" in kwargs:
+                kwargs.pop("returns")
+            return function(*args, **kwargs)
+
+        return wrapped_f
+
+    def __repr__(self) -> str:
+        attributes = f"(args: {repr(self.args)}, kwargs: {repr(self.kwargs)})"
+        return f"Dummy {self.__class__.__name__} decorator {attributes}"

src/dataclay/contrib/pycompss_dummy/api.py

@@ -0,0 +1,269 @@
+#!/usr/bin/env python3
+#
+#  Copyright 2002-2026 Barcelona Supercomputing Center (www.bsc.es)
+#
+#  Licensed under the Apache License, Version 2.0 (the "License");
+#  you may not use this file except in compliance with the License.
+#  You may obtain a copy of the License at
+#
+#      http://www.apache.org/licenses/LICENSE-2.0
+#
+#  Unless required by applicable law or agreed to in writing, software
+#  distributed under the License is distributed on an "AS IS" BASIS,
+#  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+#  See the License for the specific language governing permissions and
+#  limitations under the License.
+#
+
+# -*- coding: utf-8 -*-
+
+"""
+PyCOMPSs - dummy - api.
+
+This file defines the public PyCOMPSs API functions without functionality.
+"""
+
+import os
+
+from pycompss.util.typing_helper import typing
+
+
+def compss_start(
+    log_level: str = "off",  # pylint: disable=unused-argument
+    tracing: bool = False,  # pylint: disable=unused-argument
+    interactive: bool = False,  # pylint: disable=unused-argument
+    disable_external: bool = False,  # pylint: disable=unused-argument
+) -> None:  # pylint: disable=unused-argument
+    """Start runtime dummy.
+
+    Does nothing.
+
+    :param log_level: Log level [ True | False ].
+    :param tracing: Activate or disable tracing.
+    :param interactive: Boolean if interactive (ipython or jupyter).
+    :param disable_external: To avoid to load compss in external process.
+    :return: None
+    """
+
+
+def compss_stop(
+    code: int = 0, _hard_stop: bool = False  # pylint: disable=unused-argument
+) -> None:
+    """Stop runtime dummy.
+
+    Does nothing.
+
+    :param code: Stop code.
+    :param _hard_stop: Stop COMPSs when runtime has died.
+    :return: None
+    """
+
+
+def compss_file_exists(
+    *file_name: typing.Union[list, tuple, str],
+) -> typing.Union[bool, typing.List[typing.Union[bool, list]]]:
+    """Check if one or more files used in task exists dummy.
+
+    Check if the file/s exists.
+
+    :param file_name: The file/s name to check.
+    :return: True if exists. False otherwise.
+    """
+    ret = []  # type: typing.List[typing.Union[bool, list]]
+    for f_name in file_name:
+        if isinstance(f_name, (list, tuple)):
+            ret.append([compss_file_exists(name) for name in f_name])
+        else:
+            ret.append(os.path.exists(f_name))
+    if len(ret) == 1:
+        return ret[0]
+    return ret
+
+
+def compss_open(file_name: str, mode: str = "r") -> typing.Any:
+    """Open a file used in task dummy.
+
+    Open the given file with the defined mode (see builtin open).
+
+    :param file_name: The file name to open.
+    :param mode: Open mode. Options = [w, r+ or a, r or empty]. Default=r.
+    :return: An object of "file" type.
+    :raise IOError: If the file can not be opened.
+    """
+    return open(file_name, mode)  # pylint: disable=unspecified-encoding
+
+
+def compss_delete_file(
+    *file_name: typing.Union[list, tuple, str],
+) -> typing.Union[bool, typing.List[typing.Union[bool, list]]]:
+    """Delete one or more files used in task dummy.
+
+    Does nothing and always return True.
+
+    :param file_name: File/s name.
+    :return: Always True.
+    """
+    ret = []  # type: typing.List[typing.Union[bool, list]]
+    for f_name in file_name:
+        if isinstance(f_name, (list, tuple)):
+            ret.append([compss_delete_file(name) for name in f_name])
+        else:
+            ret.append(True)
+    if len(ret) == 1:
+        return ret[0]
+    return ret
+
+
+def compss_wait_on_file(
+    *file_name: typing.Union[list, tuple, str],
+) -> typing.Union[list, tuple, str]:
+    """Wait on file used in task dummy.
+
+    Does nothing.
+
+    :param file_name: File/s name.
+    :return: The files/s name.
+    """
+    if len(file_name) == 1:
+        return file_name[0]
+    return file_name
+
+
+def compss_wait_on_directory(
+    *directory_name: typing.Union[list, tuple, str],
+) -> typing.Union[list, tuple, str]:
+    """Wait on directory used in task dummy.
+
+    Does nothing.
+
+    :param directory_name: Directory/ies name.
+    :return: The directory/ies name.
+    """
+    if len(directory_name) == 1:
+        return directory_name[0]
+    return directory_name
+
+
+def compss_delete_object(
+    *objs: typing.Any,
+) -> typing.Union[bool, typing.List[typing.Union[bool, list]]]:
+    """Delete one or more objects used in task dummy.
+
+    Does nothing and always return True.
+
+    :param objs: Object/s to delete.
+    :return: Always True.
+    """
+    ret = []  # type: typing.List[typing.Union[bool, list]]
+    for obj in objs:
+        if isinstance(obj, (list, tuple)):
+            ret.append([compss_delete_object(elem) for elem in obj])
+        else:
+            ret.append(True)
+    if len(ret) == 1:
+        return ret[0]
+    return ret
+
+
+def compss_barrier(
+    no_more_tasks: bool = False,  # pylint: disable=unused-argument
+) -> None:
+    """Wait for all submitted tasks dummy.
+
+    Does nothing.
+
+    :param no_more_tasks: No more tasks boolean.
+    :return: None
+    """
+
+
+def compss_barrier_group(
+    group_name: str,  # pylint: disable=unused-argument
+) -> None:
+    """Wait for all submitted tasks of a group dummy.
+
+    Does nothing.
+
+    :param group_name: Name of the group.
+    :return: None
+    """
+
+
+def compss_cancel_group(
+    group_name: str,  # pylint: disable=unused-argument
+) -> None:
+    """Cancel all submitted tasks of a group dummy.
+
+    Does nothing.
+
+    :param group_name: Name of the group.
+    :return: None
+    """
+
+
+def compss_snapshot() -> None:
+    """Request a snapshot.
+
+    Does nothing.
+
+    :return: None
+    """
+
+
+def compss_wait_on(
+    *args: typing.Any, **kwargs: typing.Any  # pylint: disable=unused-argument
+) -> typing.Any:
+    """Synchronize an object used in task dummy.
+
+    Does nothing.
+
+    :param args: Objects to wait on.
+    :param kwargs: Options dictionary.
+    :return: The same objects defined as parameter.
+    """
+    ret = list(map(lambda o: o, args))
+    if len(ret) == 1:
+        return ret[0]
+    return ret
+
+
+def compss_set_wall_clock(
+    wall_clock_limit: int,  # pylint: disable=unused-argument
+) -> None:
+    """Set the application wall_clock_limit dummy.
+
+    Does nothing.
+
+    :param wall_clock_limit: Wall clock limit in seconds.
+    :return: None
+    """
+
+
+class TaskGroup:
+    """Dummy TaskGroup context manager."""
+
+    def __init__(
+        self, group_name: str, implicit_barrier: bool = True
+    ) -> None:  # pylint: disable=unused-argument
+        """Define a new group of tasks.
+
+        :param group_name: Group name.
+        :param implicit_barrier: Perform implicit barrier.
+        """
+
+    def __enter__(self) -> None:
+        """Do nothing.
+
+        :return: None
+        """
+
+    def __exit__(
+        self,
+        type: typing.Any,  # pylint: disable=redefined-builtin
+        value: typing.Any,
+        traceback: typing.Any,
+    ) -> None:
+        """Do nothing.
+
+        :return: None
+        """

src/dataclay/contrib/pycompss_dummy/constraint.py

@@ -0,0 +1,29 @@
+#!/usr/bin/env python3
+#
+#  Copyright 2002-2026 Barcelona Supercomputing Center (www.bsc.es)
+#
+#  Licensed under the Apache License, Version 2.0 (the "License");
+#  you may not use this file except in compliance with the License.
+#  You may obtain a copy of the License at
+#
+#      http://www.apache.org/licenses/LICENSE-2.0
+#
+#  Unless required by applicable law or agreed to in writing, software
+#  distributed under the License is distributed on an "AS IS" BASIS,
+#  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+#  See the License for the specific language governing permissions and
+#  limitations under the License.
+#
+
+# -*- coding: utf-8 -*-
+
+"""
+PyCOMPSs API - dummy - constraint.
+
+This file contains the dummy class constraint used as decorator.
+"""
+
+from pycompss.api.dummy._decorator import _Dummy as Dummy
+
+Constraint = Dummy  # pylint: disable=invalid-name
+constraint = Dummy  # pylint: disable=invalid-name