Skip to content

Commit 11d5b38

Browse files
committed
Update DAG endpoints
1 parent 33e50ac commit 11d5b38

3 files changed

Lines changed: 26 additions & 2 deletions

File tree

‎VERSION‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1 +1 @@
1-
0.1.0+2026.02.16T13.49.06.3NZ.c8a8e8f.dami.portfolio
1+
0.1.0+2026.02.16T13.56.23.3NZ.33e50ac.dami.portfolio

‎modules/writing_observer/VERSION‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1 +1 @@
1-
0.1.0+2026.01.02T18.41.47.3NZ.2a3d8a9.dami.portfolio
1+
0.1.0+2026.02.16T13.56.23.3NZ.33e50ac.dami.portfolio

‎modules/writing_observer/writing_observer/module.py‎

Lines changed: 24 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -113,6 +113,30 @@
113113
),
114114
fields={'text': 'text'}
115115
),
116+
"docs": q.select(
117+
q.keys(
118+
'writing_observer.reconstruct',
119+
STUDENTS=q.variable("roster"),
120+
STUDENTS_path='user_id',
121+
RESOURCES=q.variable("update_docs"),
122+
RESOURCES_path='doc_id'
123+
),
124+
fields={'text': 'text'}
125+
),
126+
'single_student_docs_by_ids': q.select(
127+
q.keys(
128+
'writing_observer.reconstruct',
129+
STUDENTS=q.parameter("student_id", required=True),
130+
STUDENTS_path='user_id',
131+
RESOURCES=q.parameter("document", required=True),
132+
RESOURCES_path='doc_id'
133+
),
134+
fields={'text': 'text'}
135+
),
136+
'single_student_nlp': process_texts(
137+
writing_data=q.variable('single_student_docs_by_ids'),
138+
options=q.parameter('nlp_options', required=False, default=[])
139+
),
116140
"doc_ids": q.select(q.keys('writing_observer.last_document', STUDENTS=q.variable("roster"), STUDENTS_path='user_id'), fields={'document_id': 'doc_id'}),
117141
'update_docs': update_via_google(runtime=q.parameter("runtime"), doc_ids=q.variable('doc_sources')),
118142
"docs": q.select(q.keys('writing_observer.reconstruct', STUDENTS=q.variable("roster"), STUDENTS_path='user_id', RESOURCES=q.variable("update_docs"), RESOURCES_path='doc_id'), fields={'text': 'text'}),

0 commit comments

Comments
 (0)