sofhiaazzhr commited on
Commit
d2f7a48
·
1 Parent(s): cb5ab32

[NO TICKET][document]: add updated_at on metadata

Browse files
src/knowledge/processing_service.py CHANGED
@@ -8,6 +8,7 @@ from src.db.postgres.models import Document as DBDocument
8
  from sqlalchemy.ext.asyncio import AsyncSession
9
  from src.middlewares.logging import get_logger
10
  from typing import List
 
11
  import sys
12
  import docx
13
  import pandas as pd
@@ -15,6 +16,8 @@ import pytesseract
15
  from pdf2image import convert_from_bytes
16
  from io import BytesIO
17
 
 
 
18
  logger = get_logger("knowledge_processing")
19
 
20
 
@@ -55,6 +58,7 @@ class KnowledgeProcessingService:
55
  metadata={
56
  "user_id": db_doc.user_id,
57
  "source_type": "document",
 
58
  "data": {
59
  "document_id": db_doc.id,
60
  "filename": db_doc.filename,
@@ -103,6 +107,7 @@ class KnowledgeProcessingService:
103
  metadata={
104
  "user_id": db_doc.user_id,
105
  "source_type": "document",
 
106
  "data": {
107
  "document_id": db_doc.id,
108
  "filename": db_doc.filename,
@@ -150,6 +155,7 @@ class KnowledgeProcessingService:
150
  metadata={
151
  "user_id": db_doc.user_id,
152
  "source_type": "document",
 
153
  "data": {
154
  "document_id": db_doc.id,
155
  "filename": db_doc.filename,
 
8
  from sqlalchemy.ext.asyncio import AsyncSession
9
  from src.middlewares.logging import get_logger
10
  from typing import List
11
+ from datetime import datetime, timezone, timedelta
12
  import sys
13
  import docx
14
  import pandas as pd
 
16
  from pdf2image import convert_from_bytes
17
  from io import BytesIO
18
 
19
+ _JAKARTA_TZ = timezone(timedelta(hours=7))
20
+
21
  logger = get_logger("knowledge_processing")
22
 
23
 
 
58
  metadata={
59
  "user_id": db_doc.user_id,
60
  "source_type": "document",
61
+ "updated_at": datetime.now(_JAKARTA_TZ).isoformat(),
62
  "data": {
63
  "document_id": db_doc.id,
64
  "filename": db_doc.filename,
 
107
  metadata={
108
  "user_id": db_doc.user_id,
109
  "source_type": "document",
110
+ "updated_at": datetime.now(_JAKARTA_TZ).isoformat(),
111
  "data": {
112
  "document_id": db_doc.id,
113
  "filename": db_doc.filename,
 
155
  metadata={
156
  "user_id": db_doc.user_id,
157
  "source_type": "document",
158
+ "updated_at": datetime.now(_JAKARTA_TZ).isoformat(),
159
  "data": {
160
  "document_id": db_doc.id,
161
  "filename": db_doc.filename,