Merge pull request #264 from ttngu207/datajoint_pipeline_pyrat

modify `subject` schema to align with pyrat - added pyrat sync routine

aeon/dj_pipeline/lab.py

@@ -74,10 +74,10 @@ class UserRole(dj.Lookup):
 @schema
 class User(dj.Lookup):
     definition = """
-    user                : varchar(32)
+    user                    : varchar(32)  # swc username
     ---
-    user_email=''       : varchar(128)
-    user_cellphone=''   : varchar(32)
+    responsible_owner=''    : varchar(32)  # pyrat username
+    responsible_id=''       : varchar(32)  # pyrat `responsible_id`
     """
 
 

aeon/dj_pipeline/populate/worker.py

@@ -2,7 +2,7 @@
 from datajoint_utilities.dj_worker import DataJointWorker, ErrorLog, WorkerLog
 from datajoint_utilities.dj_worker.worker_schema import is_djtable
 
-from aeon.dj_pipeline import acquisition, analysis, db_prefix, qc, report, tracking
+from aeon.dj_pipeline import subject, acquisition, analysis, db_prefix, qc, report, tracking
 from aeon.dj_pipeline.utils import load_metadata, streams_maker
 
 streams = streams_maker.main()
@@ -95,7 +95,20 @@ def ingest_environment_visits():
 mid_priority(report.ExperimentTimeDistribution)
 mid_priority(report.VisitDailySummaryPlot)
 
-# ---- Define worker(s) ----
+# configure a worker to handle pyrat sync
+pyrat_worker = DataJointWorker(
+    "pyrat_worker",
+    worker_schema_name=worker_schema_name,
+    db_prefix=db_prefix,
+    run_duration=-1,
+    sleep_duration=1200,
+)
+
+pyrat_worker(subject.CreatePyratIngestionTask)
+pyrat_worker(subject.PyratIngestion)
+pyrat_worker(subject.SubjectDetail)
+pyrat_worker(subject.PyratCommentWeightProcedure)
+
 # configure a worker to ingest all data streams
 streams_worker = DataJointWorker(
     "streams_worker",