@@ -1324,7 +1324,6 @@ func createRepository(e *xorm.Session, doer, u *User, repo *Repository) (err err
1324
1324
}); err != nil {
1325
1325
return fmt .Errorf ("prepareWebhooks: %v" , err )
1326
1326
}
1327
- go HookQueue .Add (repo .ID )
1328
1327
} else if err = repo .recalculateAccesses (e ); err != nil {
1329
1328
// Organization automatically called this in addRepository method.
1330
1329
return fmt .Errorf ("recalculateAccesses: %v" , err )
@@ -1393,7 +1392,16 @@ func CreateRepository(doer, u *User, opts CreateRepoOptions) (_ *Repository, err
1393
1392
}
1394
1393
}
1395
1394
1396
- return repo , sess .Commit ()
1395
+ if err = sess .Commit (); err != nil {
1396
+ return nil , err
1397
+ }
1398
+
1399
+ // Add to hook queue for created repo after session commit.
1400
+ if u .IsOrganization () {
1401
+ go HookQueue .Add (repo .ID )
1402
+ }
1403
+
1404
+ return repo , err
1397
1405
}
1398
1406
1399
1407
func countRepositories (userID int64 , private bool ) int64 {
@@ -2478,6 +2486,11 @@ func ForkRepository(doer, u *User, oldRepo *Repository, name, desc string) (_ *R
2478
2486
go HookQueue .Add (oldRepo .ID )
2479
2487
}
2480
2488
2489
+ // Add to hook queue for created repo after session commit.
2490
+ if u .IsOrganization () {
2491
+ go HookQueue .Add (repo .ID )
2492
+ }
2493
+
2481
2494
if err = repo .UpdateSize (); err != nil {
2482
2495
log .Error ("Failed to update size for repository: %v" , err )
2483
2496
}
0 commit comments