meson updated the yml codes

Author: noabauma

.github/workflows/master-test-workflow.yml

@@ -60,6 +60,8 @@ jobs:
           EOF
 
           echo "PKG_CONFIG_PATH=$PKG_CONFIG_PATH:$(pwd)/mock_install/share/pkgconfig" >> $GITHUB_ENV
+
+          export LD_PRELOAD=/usr/local/lib/libnosv.so
         
       - name: Setup
         run: source /home/hicr/.bashrc && meson setup build -Dbuildtype=debug -Db_coverage=true -DdistributedEngine=mpi -DbuildTests=true -DbuildExamples=true -DcompileWarningsAsErrors=true -DexecutionStateType=nosv,boost -DprocessingUnitType=nosv,pthreads -DbuildPyTaskR=true

.github/workflows/pr-development-workflow.yml

@@ -290,6 +290,8 @@ jobs:
           EOF
 
           echo "PKG_CONFIG_PATH=$PKG_CONFIG_PATH:$(pwd)/mock_install/share/pkgconfig" >> $GITHUB_ENV
+
+          export LD_PRELOAD=/usr/local/lib/libnosv.so
         
       - name: Setup
         run: source /home/hicr/.bashrc && meson setup build -Dbuildtype=debug -Db_coverage=true -DdistributedEngine=mpi -DbuildTests=true -DbuildExamples=true -DcompileWarningsAsErrors=true -DexecutionStateType=nosv,boost -DprocessingUnitType=nosv,pthreads -DbuildPyTaskR=true

examples/matmul/python/matmul.cpp

@@ -19,14 +19,22 @@
 
 #include <taskr/taskr.hpp>
 
+#ifdef ENABLE_INSTRUMENTATION
+  #include <tracr.hpp>
+#endif
+
 #define mytype float
 
 /**
  * Compute mmm
  */
 void matmul(taskr::Task *)
 {
-  const size_t N = 1000;
+#ifdef ENABLE_INSTRUMENTATION
+  INSTRUMENTATION_VMARKER_SET(MARK_COLOR_RED);
+#endif
+
+  const size_t N = 200;
 
   // Allocate memory
   volatile mytype *A = (mytype *)calloc(1, N * N * sizeof(mytype));
@@ -56,6 +64,10 @@ void matmul(taskr::Task *)
   free((mytype *)A);
   free((mytype *)B);
   free((mytype *)C);
+
+#ifdef ENABLE_INSTRUMENTATION
+  INSTRUMENTATION_VMARKER_RESET();
+#endif
 }
 
 PYBIND11_MODULE(cpp_matmul, m)

examples/matmul/python/matmul.py

@@ -45,15 +45,13 @@ def matmul_cpp_Driver(runtime):
 
 
 
-
-
 def matmul_numpy_Driver(runtime):
   # Initializing taskr
   runtime.initialize()
 
   def matmul_numpy(task):
     N = 1000
-    A = np.zeros((N,N))
+    A = np.empty((N,N))
     B = np.empty((N,N))
     C = np.empty((N,N))
 

examples/simple/python/main.py

@@ -13,13 +13,15 @@
   See the License for the specific language governing permissions and
   limitations under the License.
 """
-
 import taskr
+
 import simple
 
+NWORKERS = 4
+
 def main():
-    # Initialize taskr with the wanted compute manager backend and number of PUs
-    t = taskr.taskr(taskr.HiCRBackend.nosv, 2)
+    # Initialize taskr with the wanted HiCR backend and number of Workers
+    t = taskr.taskr(backend=taskr.HiCRBackend.nosv, num_workers=NWORKERS)
 
     # Get the runtime
     runtime = t.get_runtime()

examples/simple/python/simple.py

@@ -13,7 +13,6 @@
   See the License for the specific language governing permissions and
   limitations under the License.
 """
-
 import taskr
 
 NTASKS = 2
@@ -22,8 +21,8 @@ def simple(runtime):
   # Initializing taskr
   runtime.initialize()
 
+  # Create tasks
   fc = lambda task : print(f"Hello, I am task {task.getLabel()}")
-
   taskfc = taskr.Function(fc)
 
   # Adding to tasks to taskr

include/pytaskr/meson.build

@@ -2,10 +2,14 @@
 # Manually compile like this:
 # c++ -O3 -Wall -shared -std=c++11 -fPIC $(python3-config --includes) -Iextern/pybind11/include example.cpp -o example$(python3-config --extension-suffix)
 
-py = import('python').find_installation(
-  python_executable: '/usr/bin/python3',
-  pure: false
-)
+python_mod = import('python')
+
+py = python_mod.find_installation(pure: false)
+
+if not py.found()
+  py = python_mod.find_installation('/usr/bin/python3', pure: false)
+endif
+
 pybind11_dep = dependency('pybind11', required: true)
 
 py.extension_module('taskr',

include/pytaskr/pytaskr.cpp

@@ -48,7 +48,7 @@ PYBIND11_MODULE(taskr, m)
     .def("setServiceWorkerCallbackHandler", &Runtime::setServiceWorkerCallbackHandler)
     .def("setTaskWorkerCallbackHandler", &Runtime::setTaskWorkerCallbackHandler)
     .def("initialize", &Runtime::initialize)
-    .def("addTask", &Runtime::addTask, py::keep_alive<1, 2>()) // keep_alive as the task should be alive until runtime's destructor
+    .def("addTask", &Runtime::addTask, py::keep_alive<1, 2>(), py::arg("task")) // keep_alive as the task should be alive until runtime's destructor
     .def("resumeTask", &Runtime::resumeTask)
     .def("run", &Runtime::run, py::call_guard<py::gil_scoped_release>())
     .def("await_", &Runtime::await, py::call_guard<py::gil_scoped_release>()) // Release GIL is important otherwise non-finished tasks are getting blocked
@@ -57,12 +57,12 @@ PYBIND11_MODULE(taskr, m)
     .def("addService", &Runtime::addService);
 
   // TaskR's Function class
-  py::class_<Function>(m, "Function").def(py::init<const function_t>());
+  py::class_<Function>(m, "Function").def(py::init<const function_t>(), py::arg("fc"));
 
   // TaskR's Task class
   py::class_<Task>(m, "Task")
     .def(py::init<Function *, const workerId_t>(), py::arg("fc"), py::arg("workerAffinity") = -1)
-    .def(py::init<const label_t, Function *, const workerId_t>(), py::arg("label"), py::arg("fc"), py::arg("workerAffinity") = -1)
+    .def(py::init<const label_t, Function *, const workerId_t>(), py::arg("label"), py::arg("taskfc"), py::arg("workerAffinity") = -1)
     .def("getLabel", &Task::getLabel)
     .def("setLabel", &Task::setLabel)
     .def("getWorkerAffinity", &Task::getWorkerAffinity)