tests: added new dir + pytestable file for each snippet from docs

Author: Ramon Adolfo Arambula

tests/getting_started/test_job_arguements.py

@@ -0,0 +1,8 @@
+from psij import Job, JobSpec, JobExecutor
+from executor_test_params import ExecutorTestParams
+
+
+def test_getting_started_job_arguements(execparams: ExecutorTestParams) -> None:
+    ex = JobExecutor.get_instance(execparams.executor)
+    job = Job(JobSpec(executable='/bin/date', arguments=['-utc', '--debug']))
+    ex.submit(job)

tests/getting_started/test_multiple_jobs.py

@@ -0,0 +1,9 @@
+from psij import Job, JobSpec, JobExecutor
+from executor_test_params import ExecutorTestParams
+
+
+def test_getting_started_multiple_jobs(execparams: ExecutorTestParams) -> None:
+    ex = JobExecutor.get_instance(execparams.executor)
+    for _ in range(10):
+        job = Job(JobSpec(executable="/bin/date"))
+        ex.submit(job)

tests/getting_started/test_scheduling_information.py

@@ -0,0 +1,18 @@
+from psij import Job, JobSpec, JobExecutor, ResourceSpecV1, JobAttributes
+from executor_test_params import ExecutorTestParams
+
+
+def test_getting_started_scheduling_info(execparams: ExecutorTestParams) -> None:
+    executor = JobExecutor.get_instance(execparams.executor)
+
+    job = Job(
+        JobSpec(
+            executable="/bin/date",
+            resources=ResourceSpecV1(node_count=1),
+            attributes=JobAttributes(
+                queue_name="<QUEUE_NAME>", project_name="<ALLOCATION>"
+            ),
+        )
+    )
+
+    executor.submit(job)

tests/getting_started/test_single_job.py

@@ -0,0 +1,8 @@
+from psij import Job, JobSpec, JobExecutor
+from executor_test_params import ExecutorTestParams
+
+
+def test_getting_started_single_job(execparams: ExecutorTestParams) -> None:
+    ex = JobExecutor.get_instance(execparams.executor)
+    job = Job(JobSpec(executable='/bin/date', arguments=['-utc', '--debug']))
+    ex.submit(job)

tests/getting_started/test_status_callbacks.py

@@ -0,0 +1,24 @@
+import time
+from psij import Job, JobSpec, JobExecutor
+from executor_test_params import ExecutorTestParams
+
+count = 10
+
+
+def test_getting_started_scheduling_info(execparams: ExecutorTestParams) -> None:
+    def callback(job, status):
+        global count
+
+        if status.final:
+            print(f"Job {job} completed with status {status}")
+            count -= 1
+
+    ex = JobExecutor.get_instance(execparams.executor)
+    ex.set_job_status_callback(callback)
+
+    for _ in range(count):
+        job = Job(JobSpec(executable="/bin/date"))
+        ex.submit(job)
+
+    while count > 0:
+        time.sleep(0.01)