Module Import alias Assign NameStore Call AttributeLoad NameLoad attr Str ImportFrom alias ImportFrom alias alias ImportFrom alias ImportFrom alias alias alias alias alias alias alias alias alias alias alias alias FunctionDef arguments args defaults body Expr Str Expr Call NameLoad Call AttributeLoad NameLoad attr Str Assign NameStore Call NameLoad Assign NameStore Call NameLoad TryExcept body Assign NameStore Call NameLoad handlers ExceptHandler body Assign NameStore NameLoad While NameLoad body TryExcept body With Call NameLoad SubscriptLoad NameLoad Index Str NameStore body Assign NameStore Call NameLoad NameLoad NameLoad Assign NameStore Call NameLoad NameLoad NameLoad Assign NameStore Call NameLoad NameLoad NameLoad Assign NameStore Call NameLoad NameLoad NameLoad Expr Call NameLoad NameLoad SubscriptLoad NameLoad Index Str Expr Call NameLoad NameLoad SubscriptLoad NameLoad Index Str Expr Call NameLoad NameLoad If CompareLt Call NameLoad NameLoad body Continue With NameLoad NameStore body Assign NameStore Call NameLoad NameLoad Assign NameStore Call NameLoad Call NameLoad NameLoad Call AttributeLoad NameLoad attr Assign TupleStore NameStore NameStore NameStore Call NameLoad NameLoad TupleLoad NameLoad NameLoad NameLoad Expr Call AttributeLoad NameLoad attr Call AttributeLoad Str attr Call NameLoad If NameLoad body Expr Call AttributeLoad NameLoad attr Str Str NameLoad keyword Str Expr Call AttributeLoad NameLoad attr Str Str NameLoad keyword Str Expr Call AttributeLoad NameLoad attr Str Str NameLoad keyword Str Expr Call AttributeLoad NameLoad attr Str Str BinOpAdd NameLoad NameLoad keyword Str Expr Call AttributeLoad NameLoad attr Str Str NameLoad keyword Str Assign NameStore BinOpAdd Call NameLoad Num handlers ExceptHandler type NameLoad body Raise ExceptHandler body Expr Call AttributeLoad NameLoad attr Str keyword NameLoad Expr Call NameLoad Num decorator_list If CompareEq NameLoad Str body Expr Call NameLoad Call NameLoad
N/A N/A logging N/A _L N/A N/A logging getLogger openaddr.ci.run_dequeue os environ time sleep time boto connect_cloudwatch N/A db_connect db_queue TASK_QUEUE DONE_QUEUE DUE_QUEUE load_config pop_task_from_donequeue pop_task_from_duequeue setup_logger HEARTBEAT_QUEUE flush_heartbeat_queue get_recent_workers main N/A N/A N/A N/A N/A N/A N/A setup_logger N/A N/A environ get AWS_SNS_ARN N/A config N/A load_config N/A checkin_time N/A time N/A N/A N/A cw N/A connect_cloudwatch N/A N/A N/A N/A cw False N/A True N/A N/A N/A N/A N/A db_connect N/A config N/A DATABASE_URL conn N/A N/A task_Q N/A db_queue conn TASK_QUEUE N/A done_Q N/A db_queue conn DONE_QUEUE N/A due_Q N/A db_queue conn DUE_QUEUE N/A beat_Q N/A db_queue conn HEARTBEAT_QUEUE N/A N/A pop_task_from_donequeue done_Q N/A config N/A GITHUB_AUTH N/A N/A pop_task_from_duequeue due_Q N/A config N/A GITHUB_AUTH N/A N/A flush_heartbeat_queue beat_Q N/A N/A N/A time checkin_time N/A N/A N/A beat_Q db N/A N/A recent_workers N/A get_recent_workers db N/A workers_n N/A sum N/A map len N/A N/A recent_workers values N/A N/A task_n done_n due_n N/A map len N/A task_Q done_Q due_Q N/A N/A N/A _L info N/A N/A {workers_n} active workers; queue lengths: {task_n} tasks, {done_n} done, {due_n} due format N/A locals N/A cw N/A N/A N/A N/A cw put_metric_data openaddr.ci tasks queue task_n unit Count N/A N/A N/A cw put_metric_data openaddr.ci done queue done_n unit Count N/A N/A N/A cw put_metric_data openaddr.ci due queue due_n unit Count N/A N/A N/A cw put_metric_data openaddr.ci expected results N/A task_n workers_n unit Count N/A N/A N/A cw put_metric_data openaddr.ci active workers workers_n unit Count N/A checkin_time N/A N/A time 30 N/A N/A N/A KeyboardInterrupt N/A N/A N/A N/A N/A N/A N/A _L error Error in dequeue main() exc_info True N/A N/A sleep 5 N/A N/A N/A __name__ __main__ N/A N/A N/A exit N/A main