studio/flamenco
studio/flamenco
12
30
Fork 38
Code Issues 63 Pull Requests 5 Releases Wiki Activity

Resolved Task Limit error in Flamenco Manager #104201 #104203

Closed
Anish-Bharadwaj wants to merge 3 commits from Anish-Bharadwaj:104201-Resolving-Task-limit-issue-in-Flamenco-manager into main
pull from: Anish-Bharadwaj:104201-Resolving-Task-limit-issue-in-Flamenco-manager
merge into: studio:main

When changing the target branch, be careful to rebase the branch in your fork to match. See documentation.
Conversation 6 Commits 3 Files Changed 3 +5 -3
1 changed files with 5 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files
Showing only changes of commit 140115f820 - Show all commits

8
internal/manager/persistence/jobs_test.go
View File

@ -259,6 +259,9 @@ func TestCountTasksOfJobInStatus(t *testing.T) {
} }
func TestCheckIfJobsHoldLargeNumOfTasks(t *testing.T) { func TestCheckIfJobsHoldLargeNumOfTasks(t *testing.T) {
if testing.Short() {
t.Skip("Skipping test in short mode")
}
numtasks := 3500 numtasks := 3500
ctx, close, db, job, _ := jobTasksTestFixturesWithTaskNum(t, numtasks) ctx, close, db, job, _ := jobTasksTestFixturesWithTaskNum(t, numtasks)
defer close() defer close()
@ -606,14 +609,13 @@ func createTestAuthoredJobWithTasks() job_compilers.AuthoredJob {
return createTestAuthoredJob("263fd47e-b9f8-4637-b726-fd7e47ecfdae", task1, task2, task3) return createTestAuthoredJob("263fd47e-b9f8-4637-b726-fd7e47ecfdae", task1, task2, task3)
} }
//Create a Job with a Specified number of tasks
func createTestAuthoredJobWithNumTasks(numTasks int) job_compilers.AuthoredJob { func createTestAuthoredJobWithNumTasks(numTasks int) job_compilers.AuthoredJob {
//Generates all of the render jobs //Generates all of the render jobs
prevtasks := make([]*job_compilers.AuthoredTask, 0) prevtasks := make([]*job_compilers.AuthoredTask, 0)
for i := 0; i < numTasks-1; i++ { for i := 0; i < numTasks-1; i++ {
currtask := job_compilers.AuthoredTask{ currtask := job_compilers.AuthoredTask{
Name: "render-" + fmt.Sprintf("%d", i), Name: "render-" + fmt.Sprintf("%d", i),
Type: "ffmpeg", Type: "blender-render",
UUID: uuid.New(), UUID: uuid.New(),
Commands: []job_compilers.AuthoredCommand{}, Commands: []job_compilers.AuthoredCommand{},
} }
@ -719,7 +721,7 @@ func jobTasksTestFixtures(t *testing.T) (context.Context, context.CancelFunc, *D
return ctx, cancel, db, dbJob, authoredJob return ctx, cancel, db, dbJob, authoredJob
} }
//This created Test Jobs using the new function createTestAuthoredJobWithNumTasks so that you can set the number of tasks // This created Test Jobs using the new function createTestAuthoredJobWithNumTasks so that you can set the number of tasks
func jobTasksTestFixturesWithTaskNum(t *testing.T, numtasks int) (context.Context, context.CancelFunc, *DB, *Job, job_compilers.AuthoredJob) { func jobTasksTestFixturesWithTaskNum(t *testing.T, numtasks int) (context.Context, context.CancelFunc, *DB, *Job, job_compilers.AuthoredJob) {
ctx, cancel, db := persistenceTestFixtures(t, schedulerTestTimeoutlong) ctx, cancel, db := persistenceTestFixtures(t, schedulerTestTimeoutlong)