This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
open Printf | |
exception Goto of string | |
let label (name: string) = () | |
let goto (name: string) = raise (Goto name) | |
let goto_block (blocks: (string * (unit -> unit)) list): unit = | |
let rec goto_block_impl (name: string option): unit = | |
try |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
import multiprocessing | |
import re | |
from celery import Celery | |
from celery.worker.autoscale import Autoscaler as CeleryAutoscaler | |
class DAAutoscaler(CeleryAutoscaler): | |
# Try to keep the load above this point. | |
LOAD_MIN = .8 | |
# Try to keep the load below this. | |
LOAD_MAX = 1.1 |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
import sys, functools | |
def private(member): | |
@functools.wraps(member) | |
def wrapper(*function_args): | |
myself = member.__name__ | |
caller = sys._getframe(1).f_code.co_name | |
if (not caller in dir(function_args[0]) and not caller is myself): | |
raise Exception("%s called by %s is private"%(myself,caller)) | |
return member(*function_args) |