File tree Expand file tree Collapse file tree 1 file changed +2
-10
lines changed
packages/edge/services/pegboard/src/workflows/actor Expand file tree Collapse file tree 1 file changed +2
-10
lines changed Original file line number Diff line number Diff line change @@ -1393,20 +1393,12 @@ async fn clear_ports_and_resources(
1393
1393
1394
1394
let (
1395
1395
build_res,
1396
- ingress_ports,
1397
1396
( selected_resources_cpu_millicores, selected_resources_memory_mib) ,
1398
1397
_,
1399
1398
) = tokio:: try_join!(
1400
1399
ctx. op( build:: ops:: get:: Input {
1401
1400
build_ids: vec![ input. image_id] ,
1402
1401
} ) ,
1403
- sql_fetch_all!(
1404
- [ ctx, ( i64 , i64 ) , pool]
1405
- "
1406
- SELECT protocol, ingress_port_number
1407
- FROM ports_ingress
1408
- " ,
1409
- ) ,
1410
1402
sql_fetch_one!(
1411
1403
[ ctx, ( Option <i64 >, Option <i64 >) , pool]
1412
1404
"
@@ -1428,13 +1420,13 @@ async fn clear_ports_and_resources(
1428
1420
. fdb ( )
1429
1421
. await ?
1430
1422
. run ( |tx, _mc| {
1431
- let ingress_ports = ingress_ports. clone ( ) ;
1432
1423
async move {
1433
1424
destroy:: clear_ports_and_resources (
1434
1425
input. actor_id ,
1435
1426
input. image_id ,
1436
1427
Some ( build. allocation_type ) ,
1437
- ingress_ports,
1428
+ // NOTE: Ingress ports are not cleared upon reschedule, they are reused
1429
+ Vec :: new ( ) ,
1438
1430
Some ( input. runner_id ) ,
1439
1431
Some ( input. client_id ) ,
1440
1432
Some ( input. client_workflow_id ) ,
You can’t perform that action at this time.
0 commit comments