from prometheus_client import start_http_server, Summary
import sys
import time
from concurrent.futures import ThreadPoolExecutor
from timeit import default_timer

S_TIME = Summary("timing_with_time", "Time spent processing request")
S_MANUAL = Summary("timing_manually", "Time spent processing request")

@S_TIME.time()
def process_request():
    """A dummy function that takes some time."""
    start = default_timer()
    time.sleep(1)
    S_MANUAL.observe(max(default_timer() - start, 0))
    
    
if __name__ == "__main__":
    start_http_server(8000)

    threads = int(sys.argv[1])
        
    pool = ThreadPoolExecutor(max_workers=threads)
    for i in range(1000):
        pool.submit(process_request)