File tree Expand file tree Collapse file tree 1 file changed +6
-1
lines changed Expand file tree Collapse file tree 1 file changed +6
-1
lines changed Original file line number Diff line number Diff line change 30
30
SSL_KEY_PATH = os .getenv ('SSL_KEY_PATH' , 'server.key' )
31
31
SSL_CERT_PATH = os .getenv ('SSL_CERT_PATH' , 'server.crt' )
32
32
USE_SSL = os .getenv ('USE_SSL' , 'false' ).lower () == 'true'
33
+ MAX_FFMPEG_WORKERS = os .getenv ('MAX_FFMPEG_WORKERS' , 10 )
33
34
34
35
# Health check variables
35
36
HEALTHCHECK_INTERVAL = 60 # Interval in seconds (1 hour)
45
46
for binary in ALLOWED_BINARIES
46
47
}
47
48
ffmpeg_process_gauge = Gauge ("ffmpeg_process_count" , "Number of running ffmpeg processes" )
49
+ ffmpeg_max_workers_gauge = Gauge ('ffmpeg_max_workers' , 'Maximum number of allowed ffmpeg processes based on thread pool size' )
48
50
49
51
50
52
class TokenAuthValidator (grpc .AuthMetadataPlugin ):
@@ -188,9 +190,12 @@ async def is_file_valid(self, filename):
188
190
return False
189
191
190
192
async def start_grpc_server ():
191
- server = grpc .aio .server (ThreadPoolExecutor (max_workers = 10 ))
193
+ server = grpc .aio .server (ThreadPoolExecutor (max_workers = MAX_FFMPEG_WORKERS ))
192
194
ffmpeg_pb2_grpc .add_FFmpegServiceServicer_to_server (FFmpegService (), server )
193
195
196
+ # Set the ffmpeg_max_workers metric to the max_workers value
197
+ ffmpeg_max_workers_gauge .set (MAX_FFMPEG_WORKERS )
198
+
194
199
listen_addr = '0.0.0.0:50051'
195
200
if USE_SSL :
196
201
with open (SSL_CERT_PATH , 'rb' ) as f :
You can’t perform that action at this time.
0 commit comments