PyRuntime and Runtime working, now it is up to the Task class to be pybind11

Author: noabauma

.gitignore

@@ -4,4 +4,5 @@ build
 .vscode
 atlas_*.sh
 **/matrix/
-**/__pycache__/
+**/__pycache__/
+**/ovni/

examples/local/simple/meson.build

@@ -13,10 +13,10 @@ if get_option('buildTests')
 endif
 
 if get_option('buildPyTaskR')
-	pysimple_cpp = executable('pysimple_cpp', [ 'source/pysimple.cpp'], dependencies: [ TaskRBuildDep ])
+	pyruntime = executable('pyruntime', [ 'source/pyruntime.cpp'], dependencies: [ TaskRBuildDep ])
 
 	if get_option('buildTests')
-		test('pysimple_cpp', pysimple_cpp, args : [ ], suite: testSuite, workdir: pysimple_cpp.path() + '.p' )
+		test('pyruntime', pyruntime, args : [ ], suite: testSuite, workdir: pyruntime.path() + '.p' )
 
 		test('pysimple', 
 			 py,

examples/local/simple/ovni/loom.nbaumann-ThinkStation-P340.9/proc.992751/thread.992751/stream.json

@@ -7,7 +7,7 @@ def main():
     t = taskr.taskr("threading", 1)
 
     # Get the runtime
-    runtime = t.get_runtime
+    runtime = t.get_runtime()
 
     # Running simple example
     simple.simple(runtime)

examples/local/simple/ovni/loom.nbaumann-ThinkStation-P340.9/proc.992751/thread.992751/stream.obs

@@ -1,31 +1,29 @@
 import taskr
 
 def simple(runtime):
-  print(f"hello I am {runtime}")
-  
-  # # Setting onTaskFinish callback to free up task memory when it finishes (not sure if we will have this)
-  # #runtime.setTaskCallbackHandler(HiCR::tasking::Task::callback_t::onTaskFinish, [&taskr](taskr::Task *task) { delete task; })
+  # Setting onTaskFinish callback to free up task memory when it finishes (not sure if we will have this)
+  #runtime.setTaskCallbackHandler(HiCR::tasking::Task::callback_t::onTaskFinish, [&taskr](taskr::Task *task) { delete task; })
 
-  # # Initializing taskr
-  # runtime.initialize
+  # Initializing taskr
+  runtime.initialize()
 
-  # fc = lambda task : print(f"Hello, I am task {task.getLabel()}")
+  fc = lambda task : print(f"Hello, I am task {task.getLabel()}")
 
-  # # Create the taskr Tasks
-  # taskfc = taskr.Function(fc)
+  # Create the taskr Tasks
+  taskfc = taskr.Function(fc)
 
-  # # Creating the execution units (functions that the tasks will run)
-  # for i in range(1):
-  #   task = taskr.Task(i, taskfc)
+  # Creating the execution units (functions that the tasks will run)
+  for i in range(1):
+    task = taskr.Task(i, taskfc)
 
-  #   # Adding to taskr
-  #   runtime.addTask = task
+    # Adding to taskr
+    runtime.addTask(task)
 
-  # # Running taskr for the current repetition
-  # runtime.run
+  # Running taskr for the current repetition
+  runtime.run()
 
-  # # Waiting current repetition to end
-  # runtime.await_
+  # Waiting current repetition to end
+  runtime.await_()
 
-  # # Finalizing taskr
-  # runtime.finalize
+  # Finalizing taskr
+  runtime.finalize()