@@ -238,8 +263,8 @@ for.

Parameters:
    -
  • type (str) – Either ‘worker’ or ‘scheduler’
    • -
  • queues (list) –
      +
    • type (str) – Either ‘worker’ or ‘scheduler’
      • +
    • queues (list) –
      • For ‘worker’ type, the queues the worker is listening on and their weights.
        Example:
        @@ -252,13 +277,13 @@ their weights.
      -Raises:

      ValueError – When type_ does not match a specified type

      +Raises:

      ValueError – When type_ does not match a specified type

      Returns:

      ID of the message

      -Return type:

      str

      +Return type:

      str

      @@ -278,7 +303,7 @@ compatibility and not recommended for new apps.

      -Parameters:addr (str) – connection string to connect to +Parameters:addr (str) – connection string to connect to @@ -305,12 +330,12 @@ checked to ensure proper error handling.

      Parameters:
        -
      • full (int) – Hard limit on deque size. Rejects adding elements. +
      • full (int) – Hard limit on deque size. Rejects adding elements. Default: 0 - no limit
        • -
      • pfull (int) – Programmable limit on deque size, defaults +
      • pfull (int) – Programmable limit on deque size, defaults to full length
      • on_full (func) – callback to call when full limit is hit
        • -
      • initial (iter) – The initial iteratable used to contruct the deque
        • +
      • initial (iter) – The initial iteratable used to contruct the deque
      @@ -344,7 +369,7 @@ called. -Return type:bool +Return type:bool @@ -370,7 +395,7 @@ called. -Return type:bool +Return type:bool @@ -391,7 +416,7 @@ called. -Return type:bool +Return type:bool @@ -407,7 +432,7 @@ called. Returns:True if the deque contains 0 items. False otherwise -Return type:bool +Return type:bool @@ -424,7 +449,7 @@ called. Returns:True if the deque contains at least full items. False otherwise -Return type:bool +Return type:bool @@ -441,7 +466,7 @@ otherwise Returns:True if the deque contains at least pfull items. False otherwise -Return type:bool +Return type:bool @@ -456,7 +481,7 @@ False otherwise Returns:the last (right-most) element of the deque -Return type:object +Return type:object @@ -471,7 +496,7 @@ False otherwise Returns:the first (left-most) element of the deque -Return type:object +Return type:object @@ -486,7 +511,7 @@ False otherwise Returns:the last (right-most) element of the deque -Return type:object +Return type:object @@ -501,7 +526,7 @@ False otherwise Returns:the first (left-most) element of the deque -Return type:object +Return type:object @@ -515,7 +540,7 @@ False otherwise -Parameters:item (object) – The item to remove from the deque +Parameters:item (object) – The item to remove from the deque @@ -548,7 +573,7 @@ met.

      -Parameters:now (float) – The time to use to check if death has occurred. If +Parameters:now (float) – The time to use to check if death has occurred. If this value is None, then utils.timeutils.monotonic() is used. @@ -558,7 +583,7 @@ is used. -Return type:bool +Return type:bool @@ -578,11 +603,11 @@ is used. -Parameters:socket (socket) – The eMQP socket to send the message to +Parameters:socket (socket) – The eMQP socket to send the message to Returns:ID of the message -Return type:str +Return type:str @@ -636,7 +661,7 @@ on it’s own

      Parameters:
      • message – message to send to something
        • -
      • protocol_version (str) – protocol version. it’s good practice, but +
      • protocol_version (str) – protocol version. it’s good practice, but you may explicitly specify None to skip adding the version
      @@ -658,10 +683,10 @@ like this

      Parameters:
        -
      • message (tuple) – Raw message to send.
        • -
      • protocol_version (str) – protocol version. it’s good practice but +
      • message (tuple) – Raw message to send.
        • +
      • protocol_version (str) – protocol version. it’s good practice but you may explicitly specify None to skip adding the version
        • -
      • _recipient_id (object) – When using a zmq.ROUTER you must +
      • _recipient_id (object) – When using a zmq.ROUTER you must specify the the recipient id of the remote socket
      @@ -675,16 +700,19 @@ specify the the recipient id of the remote socket