fix: resolve pr review comments

skwowet · skwowet · commit 3d1cd303278f · 2026-07-01T23:18:20.000+05:30
Signed-off-by: Yeganathan S &lt;63534555+skwowet@users.noreply.github.com&gt;
diff --git a/services/apps/git_integration/src/crowdgit/services/affiliation/affiliation_service.py b/services/apps/git_integration/src/crowdgit/services/affiliation/affiliation_service.py
@@ -502,15 +502,15 @@ async def parse_affiliations(self, content: str) -> tuple[list[AffiliationInfoIt
 
         semaphore = asyncio.Semaphore(self.MAX_CONCURRENT_CHUNKS)
 
-        async def process_chunk(chunk_index: int, chunk: str):
+        async def process_chunk(chunk: str):
             async with semaphore:
                 return await invoke_bedrock(
                     self.get_extraction_prompt(chunk),
                     pydantic_model=AffiliationParseOutput,
                 )
 
         chunk_results = await asyncio.gather(
-            *[process_chunk(i, chunk) for i, chunk in enumerate(chunks, 1)]
+            *[process_chunk(chunk) for chunk in chunks]
         )
 
         affiliations: list[AffiliationInfoItem] = []

Original file line number	Diff line number	Diff line change
`@@ -502,15 +502,15 @@ async def parse_affiliations(self, content: str) -> tuple[list[AffiliationInfoIt`
`502`	`502`
`503`	`503`	`semaphore = asyncio.Semaphore(self.MAX_CONCURRENT_CHUNKS)`
`504`	`504`
`505`		`- async def process_chunk(chunk_index: int, chunk: str):`
	`505`	`+ async def process_chunk(chunk: str):`
`506`	`506`	`async with semaphore:`
`507`	`507`	`return await invoke_bedrock(`
`508`	`508`	`self.get_extraction_prompt(chunk),`
`509`	`509`	`pydantic_model=AffiliationParseOutput,`
`510`	`510`	`)`
`511`	`511`
`512`	`512`	`chunk_results = await asyncio.gather(`
`513`		`- *[process_chunk(i, chunk) for i, chunk in enumerate(chunks, 1)]`
	`513`	`+ *[process_chunk(chunk) for chunk in chunks]`
`514`	`514`	`)`
`515`	`515`
`516`	`516`	`affiliations: list[AffiliationInfoItem] = []`