Module ImportFrom alias Import alias ImportFrom alias alias Import alias Import alias Import alias TryExcept body ImportFrom alias alias handlers ExceptHandler type NameLoad body ImportFrom alias alias ImportFrom alias ImportFrom alias Import alias ImportFrom alias Assign NameStore Call AttributeLoad NameLoad attr NameLoad Assign NameStore ListLoad Str ClassDef bases AttributeLoad NameLoad attr body Expr Str FunctionDef arguments args NameParam NameParam NameParam defaults body Assert Call NameLoad NameLoad NameLoad Assert Call NameLoad AttributeLoad NameLoad attr Expr Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad Assign AttributeStore NameLoad attr NameLoad Assign AttributeStore NameLoad attr NameLoad decorator_list FunctionDef arguments args NameParam defaults body Expr Str For NameStore Call NameLoad AttributeLoad AttributeLoad NameLoad attr attr Str body Expr Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad decorator_list FunctionDef arguments args NameParam defaults body Expr Str Return BoolOpAnd UnaryOpNot Call AttributeLoad NameLoad attr Call AttributeLoad AttributeLoad NameLoad attr attr decorator_list decorator_list FunctionDef arguments args defaults body Expr Str Assign NameStore Call AttributeLoad NameLoad attr Assign NameStore Call AttributeLoad NameLoad attr NameLoad Assign NameStore Call AttributeLoad NameLoad attr Expr Call AttributeLoad NameLoad attr NameLoad Return Call AttributeLoad NameLoad attr Str Str keyword NameLoad decorator_list ClassDef bases body FunctionDef arguments args NameParam NameParam NameParam NameParam NameParam NameParam defaults Str Str Str Str Num body Assign AttributeStore NameLoad attr NameLoad Assign AttributeStore NameLoad attr NameLoad Assign AttributeStore NameLoad attr BinOpMod Str TupleLoad NameLoad NameLoad Assign AttributeStore NameLoad attr NameLoad Assign AttributeStore NameLoad attr Call NameLoad Assign AttributeStore NameLoad attr Call AttributeLoad NameLoad attr keyword NameLoad Assign AttributeStore NameLoad attr SubscriptLoad AttributeLoad NameLoad attr Index Str Assign AttributeStore NameLoad attr Call NameLoad Assign AttributeStore NameLoad attr NameLoad Assign AttributeStore NameLoad attr Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr decorator_list FunctionDef arguments args NameParam NameParam defaults Num body Expr Call AttributeLoad NameLoad attr Str Assign NameStore Dict Str Str Call AttributeLoad Str attr AttributeLoad NameLoad attr AttributeLoad NameLoad attr NameLoad TryExcept body Assign NameStore Call AttributeLoad Call AttributeLoad Call AttributeLoad Call AttributeLoad AttributeLoad NameLoad attr attr attr attr keyword Call AttributeLoad Str attr AttributeLoad NameLoad attr AttributeLoad NameLoad attr keyword NameLoad attr handlers ExceptHandler type NameLoad name NameStore body Expr Call AttributeLoad NameLoad attr Str Raise Return NameLoad decorator_list FunctionDef arguments args NameParam NameParam defaults Num body Assign NameStore NameLoad Expr Call AttributeLoad NameLoad attr Str TryExcept body Expr Call AttributeLoad Call AttributeLoad Call AttributeLoad Call AttributeLoad AttributeLoad NameLoad attr attr attr attr keyword Call AttributeLoad Str attr AttributeLoad NameLoad attr AttributeLoad NameLoad attr attr Expr Call AttributeLoad NameLoad attr Str handlers ExceptHandler type NameLoad name NameStore body If CompareEq AttributeLoad AttributeLoad NameLoad attr attr Num body Assign NameStore Call AttributeLoad NameLoad attr keyword NameLoad orelse Raise orelse Assign NameStore Call AttributeLoad NameLoad attr keyword NameLoad Expr Call AttributeLoad NameLoad attr BinOpMod Str NameLoad Return NameLoad decorator_list FunctionDef arguments args NameParam defaults body Assign NameStore Num Assign NameStore Dict Str Str NameLoad NameLoad Expr Call AttributeLoad NameLoad attr Str Assign NameStore Call AttributeLoad Call AttributeLoad Call AttributeLoad Call AttributeLoad AttributeLoad NameLoad attr attr attr attr keyword SubscriptLoad AttributeLoad NameLoad attr Index Str keyword NameLoad attr If CompareIn Str NameLoad body Expr Call AttributeLoad NameLoad attr BinOpMod Str Call NameLoad Call AttributeLoad NameLoad attr Str Assign AttributeStore NameLoad attr Call AttributeLoad NameLoad attr Return Call AttributeLoad NameLoad attr Str orelse Return ListLoad decorator_list FunctionDef arguments args NameParam NameParam defaults body Assign NameStore Dict Str Str SubscriptLoad NameLoad Index Str AttributeLoad NameLoad attr Assign NameStore Call AttributeLoad Call AttributeLoad Call AttributeLoad Call AttributeLoad AttributeLoad NameLoad attr attr attr attr keyword SubscriptLoad AttributeLoad NameLoad attr Index Str keyword NameLoad attr Return NameLoad decorator_list FunctionDef arguments args NameParam NameParam defaults body Assign NameStore Call NameLoad AttributeLoad NameLoad attr keyword NameLoad keyword NameLoad Assign NameStore Call NameLoad AttributeLoad NameLoad attr AttributeLoad NameLoad attr Expr Call AttributeLoad NameLoad attr While UnaryOpNot Call AttributeLoad NameLoad attr body While NameLoad body TryExcept body Assign NameStore Call AttributeLoad AttributeLoad NameLoad attr attr handlers ExceptHandler type NameLoad body Break orelse Expr Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad Assign NameStore BinOpSub Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr If CompareGt AttributeLoad NameLoad attr BinOpSub AttributeLoad NameLoad attr Num body Expr Call AttributeLoad NameLoad attr Str TryExcept body Assign NameStore Call AttributeLoad NameLoad attr NameLoad Assign AttributeStore NameLoad attr Num Assign AttributeStore NameLoad attr Call AttributeLoad NameLoad attr handlers ExceptHandler type NameLoad name NameStore body If CompareEq AttributeLoad AttributeLoad NameLoad attr attr Num body Expr Call AttributeLoad NameLoad attr Str AugAssignAdd AttributeStore NameLoad attr Num If CompareGt AttributeLoad NameLoad attr Num body Expr Call AttributeLoad NameLoad attr Str Raise Expr Call AttributeLoad NameLoad attr Num Assign NameStore Call AttributeLoad NameLoad attr If CompareIsNot NameLoad NameLoad body Expr Call AttributeLoad NameLoad attr Str Return NameLoad decorator_list FunctionDef arguments args NameParam NameParam defaults body For NameStore NameLoad body Assign NameStore Call AttributeLoad NameLoad attr Str Expr Call AttributeLoad NameLoad attr BinOpMod Str Call AttributeLoad NameLoad attr Str If NameLoad body Assign NameStore ListLoad Assign NameStore Call AttributeLoad NameLoad attr NameLoad Expr Call AttributeLoad NameLoad attr Call AttributeLoad NameLoad attr Str Assign NameStore Dict Str NameLoad If NameLoad body Expr Call AttributeLoad NameLoad attr BinOpMod Str NameLoad Assign NameStore Call AttributeLoad Call AttributeLoad Call AttributeLoad Call AttributeLoad AttributeLoad NameLoad attr attr attr attr keyword SubscriptLoad AttributeLoad NameLoad attr Index Str keyword NameLoad attr decorator_list FunctionDef arguments args NameParam defaults body While NameLoad body Assign NameStore Call AttributeLoad NameLoad attr If NameLoad body Expr Call AttributeLoad NameLoad attr NameLoad decorator_list decorator_list
N/A datetime datetime N/A logging subprocess PIPE Popen N/A sys N/A threading N/A time N/A N/A Queue Queue Empty N/A N/A N/A ImportError N/A queue Queue Empty apiclient discovery apiclient.errors HttpError N/A httplib2 oauth2client.client GoogleCredentials N/A log N/A N/A logging getLogger __name__ N/A PUBSUB_SCOPES N/A https://www.googleapis.com/auth/pubsub AsynchronousFileReader N/A N/A threading Thread N/A N/A 
    Helper class to implement asynchronous reading of a file
    in a separate thread. Pushes read lines on a queue to
    be consumed in another thread.
     __init__ N/A N/A self fd queue N/A N/A N/A N/A isinstance queue Queue N/A N/A callable N/A fd readline N/A N/A N/A N/A threading Thread __init__ self N/A N/A self _fd fd N/A N/A self _queue queue N/A run N/A N/A self N/A N/A N/A The body of the tread: read lines and put them on the queue. N/A line N/A iter N/A N/A self _fd readline N/A N/A N/A N/A N/A self _queue put line N/A eof N/A N/A self N/A N/A N/A Check whether there is no more content to expect. N/A N/A N/A N/A N/A self is_alive N/A N/A N/A self _queue empty N/A N/A get_client N/A N/A N/A N/A N/A Creates Pub/Sub client and returns it. N/A credentials N/A N/A GoogleCredentials get_application_default N/A credentials N/A N/A credentials create_scoped PUBSUB_SCOPES N/A http N/A N/A httplib2 Http N/A N/A N/A credentials authorize http N/A N/A N/A discovery build pubsub v1beta2 http http N/A Executor N/A N/A __init__ N/A N/A self topic project subname task_cmd deadline N/A mytopic myproject default_sub sleep 20 60 N/A N/A N/A self topic topic N/A N/A self project project N/A N/A self subname N/A %s_%s N/A topic subname N/A N/A self task_cmd task_cmd N/A N/A self client N/A get_client N/A N/A self sub N/A N/A self get_subscription deadline deadline N/A N/A self ackdeadline N/A N/A self sub N/A ackDeadlineSeconds N/A N/A self io_queue N/A Queue N/A N/A self lease_start None N/A N/A self job_log N/A N/A logging getLogger N/A self subname N/A create_subscription N/A N/A self deadline N/A 60 N/A N/A N/A N/A log debug creating subscription N/A body N/A topic ackDeadlineSeconds N/A N/A projects/{}/topics/{} format N/A self project N/A self topic deadline N/A N/A N/A subscription N/A N/A N/A N/A N/A N/A N/A N/A N/A self client projects subscriptions create name N/A N/A projects/{}/subscriptions/{} format N/A self project N/A self subname body body execute N/A N/A N/A Exception N/A e N/A N/A N/A N/A log critical unable to create subscription N/A N/A subscription N/A get_subscription N/A N/A self deadline N/A 60 N/A N/A sub None N/A N/A N/A log debug getting subscription N/A N/A N/A N/A N/A N/A N/A N/A N/A N/A N/A N/A self client projects subscriptions delete subscription N/A N/A projects/{}/subscriptions/{} format N/A self project N/A self subname execute N/A N/A N/A log debug deleted existing subscription N/A N/A N/A HttpError N/A e N/A N/A N/A N/A N/A e resp status 404 N/A N/A sub N/A N/A self create_subscription deadline deadline N/A N/A N/A N/A sub N/A N/A self create_subscription deadline deadline N/A N/A N/A log debug N/A subscription %s sub N/A sub N/A get_messages N/A N/A self N/A N/A N/A batch_size 1 N/A body N/A returnImmediately maxMessages False batch_size N/A N/A N/A log debug pulling messages N/A resp N/A N/A N/A N/A N/A N/A N/A N/A N/A self client projects subscriptions pull subscription N/A N/A self sub N/A name body body execute N/A N/A receivedMessages resp N/A N/A N/A N/A log debug N/A number msgs: %s N/A len N/A N/A resp get receivedMessages N/A N/A self lease_start N/A N/A datetime now N/A N/A N/A resp get receivedMessages N/A N/A N/A N/A extend_lease N/A N/A self msg N/A N/A N/A body N/A ackId ackDeadlineSeconds N/A msg N/A ackId N/A self ackdeadline N/A resp N/A N/A N/A N/A N/A N/A N/A N/A N/A self client projects subscriptions modifyAckDeadline subscription N/A N/A self sub N/A name body body execute N/A resp N/A run_task N/A N/A self msg N/A N/A N/A proc N/A Popen N/A self task_cmd stdout PIPE shell True N/A stdout_reader N/A AsynchronousFileReader N/A proc stdout N/A self io_queue N/A N/A N/A stdout_reader start N/A N/A N/A N/A stdout_reader eof N/A N/A True N/A N/A N/A N/A line N/A N/A N/A self io_queue get_nowait N/A N/A N/A Empty N/A N/A N/A N/A N/A N/A N/A self job_log info line N/A lease_age N/A N/A N/A datetime now N/A self lease_start N/A N/A N/A lease_age seconds N/A N/A self ackdeadline 20 N/A N/A N/A N/A log debug extending lease N/A N/A N/A resp N/A N/A self extend_lease msg N/A N/A self extend_error_ct 0 N/A N/A self lease_start N/A N/A datetime now N/A N/A N/A HttpError N/A e N/A N/A N/A N/A N/A e resp status 503 N/A N/A N/A N/A log warning PubSub returned 503 N/A N/A self extend_error_ct 1 N/A N/A N/A self extend_error_ct 5 N/A N/A N/A N/A log critical Too many error responses to extend request N/A N/A N/A N/A time sleep 1 N/A retcode N/A N/A proc poll N/A N/A retcode None N/A N/A N/A N/A log debug process ended N/A retcode N/A process_messages N/A N/A self msgs N/A N/A N/A received_message msgs N/A N/A pubsub_message N/A N/A received_message get message N/A N/A N/A log debug N/A processing %s N/A N/A received_message get ackId N/A pubsub_message N/A N/A ack_ids N/A N/A cmd_retcode N/A N/A self run_task received_message N/A N/A N/A ack_ids append N/A N/A received_message get ackId N/A ack_body N/A ackIds ack_ids N/A ack_ids N/A N/A N/A N/A log debug N/A acking %s ack_ids N/A ack_resp N/A N/A N/A N/A N/A N/A N/A N/A N/A self client projects subscriptions acknowledge subscription N/A N/A self sub N/A name body ack_body execute N/A watch_topic N/A N/A self N/A N/A N/A True N/A N/A msgs N/A N/A self get_messages N/A msgs N/A N/A N/A N/A self process_messages msgs N/A N/A