File tree Expand file tree Collapse file tree 2 files changed +5
-15
lines changed
Expand file tree Collapse file tree 2 files changed +5
-15
lines changed Original file line number Diff line number Diff line change 11services :
22 server :
3- image : skeptrune/jukebox-server:v0.0.19
3+ image : skeptrune/jukebox-server:v0.0.20
44 ports :
55 - " ${SERVER_PORT}:${SERVER_INTERNAL_PORT}"
66 env_file :
@@ -40,7 +40,7 @@ services:
4040 window : 60s
4141
4242 worker1 :
43- image : skeptrune/jukebox-worker:v0.0.19
43+ image : skeptrune/jukebox-worker:v0.0.20
4444 ports :
4545 - " ${WORKER1_PORT}:${WORKER1_INTERNAL_PORT}"
4646 env_file :
@@ -74,7 +74,7 @@ services:
7474 retries : 3
7575
7676 worker2 :
77- image : skeptrune/jukebox-worker:v0.0.19
77+ image : skeptrune/jukebox-worker:v0.0.20
7878 ports :
7979 - " ${WORKER2_PORT}:${WORKER2_INTERNAL_PORT}"
8080 env_file :
@@ -108,7 +108,7 @@ services:
108108 retries : 3
109109
110110 worker3 :
111- image : skeptrune/jukebox-worker:v0.0.19
111+ image : skeptrune/jukebox-worker:v0.0.20
112112 ports :
113113 - " ${WORKER3_PORT}:${WORKER3_INTERNAL_PORT}"
114114 env_file :
@@ -142,7 +142,7 @@ services:
142142 retries : 3
143143
144144 frontend :
145- image : skeptrune/jukebox-spa:v0.0.19
145+ image : skeptrune/jukebox-spa:v0.0.20
146146 env_file :
147147 - .env
148148 ports :
Original file line number Diff line number Diff line change @@ -289,16 +289,6 @@ async function workerLoop() {
289289 `Stream received data for ${ youtube_id } : ${ chunk . length } bytes (chunk #${ chunkCountReceived } )`
290290 ) ;
291291 } ) ;
292- // Cleanup inactivity and start timeouts on end/close
293- const cleanupTimeouts = ( ) => {
294- console . log (
295- `Stream ended for ${ youtube_id } , cleaning up timeouts`
296- ) ;
297- if ( inactivityTimeout ) clearTimeout ( inactivityTimeout ) ;
298- if ( startTimeout ) clearTimeout ( startTimeout ) ;
299- } ;
300- stream . on ( "end" , cleanupTimeouts ) ;
301- stream . on ( "close" , cleanupTimeouts ) ;
302292 abortController . signal . addEventListener ( "abort" , ( ) => {
303293 if ( inactivityTimeout ) clearTimeout ( inactivityTimeout ) ;
304294 if ( startTimeout ) clearTimeout ( startTimeout ) ;
You can’t perform that action at this time.
0 commit comments