emrahgunduz

import asyncio
import json
import threading
from aiohttp import web


def healthcheck_response ( data, *, text=None, body=None, status=200, reason=None, headers=None, content_type="application/json", dumps=json.dumps ):
  return web.json_response(
      data,
      text=text,

emrahgunduz

from threading import Lock


class Counter( object ):
  def __init__ ( self ):
    self.__value = 0
    self.__lock = Lock()

  def increment ( self, by_value: int = 1 ):
    with self.__lock:

emrahgunduz

from __future__ import annotations
from typing import Union
import os
import uuid
import json
from datetime import datetime
from threading import Lock


class Log( object ):

emrahgunduz

from threading import Lock
import time


class Took:
  def __init__ ( self ):
    self.__lock = Lock()
    with self.__lock:
      self.__start = time.time()
      self.__total = time.time()

emrahgunduz

import matplotlib.pyplot as plt
%matplotlib inline
plt.rcParams["figure.figsize"] = 12,12

def plot_images(images, columns=4):
    total = len(images)
    nrow = ceil(total / columns)
    ncol = columns

    fig = plt.figure(figsize=(ncol+1, nrow+1)) 

emrahgunduz

from threading import Timer
from typing import ClassVar
from typing import Optional


class SelfRunner( object ):
  _timeout: ClassVar[ float ] = 10.0
  _timer: Optional[ Timer ] = None
  _end_called: bool = False

emrahgunduz

import asyncio
from asyncio import Future
from collections import Callable
from typing import ClassVar
from typing import Optional


class Timer:
  _task: Optional[ Future ] = None
  _timeout: ClassVar[ float ]