sortedcord/alemno-payments
1
0
Fork 0
mirror of https://github.com/sortedcord/alemno-payments.git synced 2026-07-22 04:02:49 +05:30
Code Issues Packages Projects Releases Wiki Activity

feat: Added get_by_id and update in job repository

Browse Source
This commit is contained in:
Aditya Gupta
2026-06-29 14:00:08 +05:30
parent 2cafef095d
commit fdfd5b54f8
1 changed files with 10 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
app/repositories/job_repository.py
View File

@@ -14,6 +14,10 @@ class JobRepository:
await self.db.flush()
return job
async def get_by_id(self, job_id: str) -> Optional[Job]:
query = select(Job).where(Job.id == job_id)
result = await self.db.execute(query)
return result.scalar_one_or_none()
async def list_all(self, status: Optional[str] = None) -> List[Job]:
query = select(Job)
@@ -23,3 +27,9 @@ class JobRepository:
result = await self.db.execute(query)
return list(result.scalars().all())
async def update(self, job: Job, **kwargs) -> Job:
for key, value in kwargs.items():
if hasattr(job, key):
setattr(job, key, value)
await self.db.flush()
return job