fix: clean up workflow log streams when pullrequest is closed/merged

Quynh Nguyen · quynhnhatnguyen · commit 942269cc555c · 2025-09-12T23:29:25.000-07:00
Signed-off-by: quynhnhatnguyen &lt;quynhnhat.nguyen@gmail.com&gt;
diff --git a/server/events/pull_closed_executor.go b/server/events/pull_closed_executor.go
@@ -96,6 +96,14 @@ func (p *PullClosedExecutor) CleanUpPull(logger logging.SimpleLogging, repo mode
 			}
 			p.LogStreamResourceCleaner.CleanUp(jobContext)
 		}
+
+		// Clean up log streams associated with the pull request workflow.
+		jobContext := jobs.PullInfo{
+			PullNum:      pull.Num,
+			Repo:         pull.BaseRepo.Name,
+			RepoFullName: pull.BaseRepo.FullName,
+		}
+		p.LogStreamResourceCleaner.CleanUp(jobContext)
 	}
 
 	if err := p.WorkingDir.Delete(logger, repo, pull); err != nil {

Original file line number	Diff line number	Diff line change
`@@ -96,6 +96,14 @@ func (p *PullClosedExecutor) CleanUpPull(logger logging.SimpleLogging, repo mode`
`96`	`96`	`}`
`97`	`97`	`p.LogStreamResourceCleaner.CleanUp(jobContext)`
`98`	`98`	`}`
	`99`	`+`
	`100`	`+ // Clean up log streams associated with the pull request workflow.`
	`101`	`+ jobContext := jobs.PullInfo{`
	`102`	`+ PullNum: pull.Num,`
	`103`	`+ Repo: pull.BaseRepo.Name,`
	`104`	`+ RepoFullName: pull.BaseRepo.FullName,`
	`105`	`+ }`
	`106`	`+ p.LogStreamResourceCleaner.CleanUp(jobContext)`
`99`	`107`	`}`
`100`	`108`
`101`	`109`	`if err := p.WorkingDir.Delete(logger, repo, pull); err != nil {`