Reformat with latest black

Author: palango

raiden/api/exceptions.py

@@ -2,7 +2,7 @@
 
 
 class ChannelNotFound(RaidenValidationError):
-    """ Raised when a provided channel via the REST api is not found in the
+    """Raised when a provided channel via the REST api is not found in the
     internal data structures.
     """
 

raiden/api/python.py

@@ -280,7 +280,7 @@ def token_network_connect(
         initial_channel_target: int = 3,
         joinable_funds_target: float = 0.4,
     ) -> None:
-        """ Automatically maintain channels open for the given token network.
+        """Automatically maintain channels open for the given token network.
 
         Args:
             token_address: the ERC20 token network to connect to.
@@ -379,7 +379,7 @@ def channel_open(
         reveal_timeout: BlockTimeout = None,
         retry_timeout: NetworkTimeout = DEFAULT_RETRY_TIMEOUT,
     ) -> ChannelID:
-        """ Open a channel with the peer at `partner_address`
+        """Open a channel with the peer at `partner_address`
         with the given `token_address`.
         """
         if settle_timeout is None:
@@ -532,7 +532,7 @@ def channel_open(
         return channel_state.identifier
 
     def mint_token_for(self, token_address: TokenAddress, to: Address, value: TokenAmount) -> None:
-        """ Try to mint `value` units of the token at `token_address` and
+        """Try to mint `value` units of the token at `token_address` and
         assign them to `to`, using `mintFor`.
 
         Raises:
@@ -552,7 +552,7 @@ def set_total_channel_withdraw(
         total_withdraw: WithdrawAmount,
         retry_timeout: NetworkTimeout = DEFAULT_RETRY_TIMEOUT,
     ) -> None:
-        """ Set the `total_withdraw` in the channel with the peer at `partner_address` and the
+        """Set the `total_withdraw` in the channel with the peer at `partner_address` and the
         given `token_address`.
 
         Raises:
@@ -625,7 +625,7 @@ def set_total_channel_deposit(
         total_deposit: TokenAmount,
         retry_timeout: NetworkTimeout = DEFAULT_RETRY_TIMEOUT,
     ) -> None:
-        """ Set the `total_deposit` in the channel with the peer at `partner_address` and the
+        """Set the `total_deposit` in the channel with the peer at `partner_address` and the
         given `token_address` in order to be able to do transfers.
 
         Raises:
@@ -781,7 +781,7 @@ def set_reveal_timeout(
         partner_address: Address,
         reveal_timeout: BlockTimeout,
     ) -> None:
-        """ Set the `reveal_timeout` in the channel with the peer at `partner_address` and the
+        """Set the `reveal_timeout` in the channel with the peer at `partner_address` and the
         given `token_address`.
 
         Raises:

raiden/api/rest.py

@@ -881,7 +881,9 @@ def get_raiden_events_payment_history_with_timestamps(
                 )
             else:
                 log.warning(
-                    "Unexpected event", node=self.checksum_address, unexpected_event=event.event,
+                    "Unexpected event",
+                    node=self.checksum_address,
+                    unexpected_event=event.event,
                 )
 
             result.append(serialized_event)
@@ -1053,7 +1055,8 @@ def _updated_channel_state_from_addresses(
         if updated_channel_state:
             result = self.channel_schema.dump(updated_channel_state)
             result[CHANNEL_NETWORK_STATE] = views.get_node_network_status(
-                chain_state, updated_channel_state.partner_state.address,
+                chain_state,
+                updated_channel_state.partner_state.address,
             ).value
         else:
             result = None
@@ -1074,7 +1077,8 @@ def _updated_channel_state(
         if updated_channel_state:
             result = self.channel_schema.dump(updated_channel_state)
             result[CHANNEL_NETWORK_STATE] = views.get_node_network_status(
-                chain_state, updated_channel_state.partner_state.address,
+                chain_state,
+                updated_channel_state.partner_state.address,
             ).value
         else:
             result = None

raiden/blockchain/decode.py

@@ -87,7 +87,8 @@ def contractreceivenewtokennetwork_from_event(
     return ContractReceiveNewTokenNetwork(
         token_network_registry_address=token_network_registry_address,
         token_network=TokenNetworkState(
-            address=token_network_address, token_address=token_address,
+            address=token_network_address,
+            token_address=token_address,
         ),
         transaction_hash=event.transaction_hash,
         block_number=event.block_number,

raiden/blockchain/events.py

@@ -116,7 +116,7 @@ def get_contract_events(
     from_block: BlockIdentifier = GENESIS_BLOCK_NUMBER,
     to_block: BlockIdentifier = BLOCK_ID_LATEST,
 ) -> List[Dict]:
-    """ Query the blockchain for all events of the smart contract at
+    """Query the blockchain for all events of the smart contract at
     `contract_address` that match the filters `topics`, `from_block`, and
     `to_block`.
     """
@@ -298,7 +298,7 @@ def fetch_all_events_for_a_deployment(
     start_block: BlockNumber,
     target_block: BlockNumber,
 ) -> Iterable[Dict]:
-    """ Read all the events of a whole deployment, starting at the network
+    """Read all the events of a whole deployment, starting at the network
     registry, and following the registered networks.
     """
 

raiden/blockchain/exceptions.py

@@ -17,14 +17,14 @@ class UnknownRaidenEventType(RaidenUnrecoverableError):
 
 
 class EthGetLogsTimeout(RaidenRecoverableError):
-    """ Raised when an eth.getLogs RPC call caused a ReadTimeout exception.
+    """Raised when an eth.getLogs RPC call caused a ReadTimeout exception.
 
     It is used to automatically tune the block batching size.
     """
 
 
 class BlockBatchSizeTooSmall(RaidenUnrecoverableError):
-    """ Raised when the block batch size would have to be reduced below the minimum allowed value.
+    """Raised when the block batch size would have to be reduced below the minimum allowed value.
 
     This is an unrecoverable error since it indicates that either the connected Eth-node or the
     network connection is not capable of supporting minimum performance requirements for the

raiden/blockchain/filters.py

@@ -70,7 +70,7 @@ def get_filter_args_for_all_events_from_channel(
 
 
 def decode_event(abi: ABI, event_log: LogReceipt) -> EventData:
-    """ Helper function to unpack event data using a provided ABI
+    """Helper function to unpack event data using a provided ABI
 
     Args:
         abi: The ABI of the contract, not the ABI of the event

raiden/blockchain/state.py

@@ -221,7 +221,8 @@ def get_contractreceivechannelbatchunlock_data_from_event(
 
 
 def get_contractreceivechannelnew_data_from_event(
-    chain_state: ChainState, event: DecodedEvent,
+    chain_state: ChainState,
+    event: DecodedEvent,
 ) -> Optional[NewChannelDetails]:
     token_network_address = TokenNetworkAddress(event.originating_contract)
     data = event.event_data

raiden/blockchain/utils.py

@@ -10,7 +10,7 @@
 
 
 class BlockBatchSizeAdjuster:
-    """ Helper to dynamically adjust the block batch size.
+    """Helper to dynamically adjust the block batch size.
 
     Internally it uses an exponential function of base ``base`` onto which the block range given
     in the config is mapped.
@@ -48,7 +48,7 @@ def _log(self, previous_batch_size: BlockNumber) -> None:
             )
 
     def increase(self) -> None:
-        """ Increase the block batch size.
+        """Increase the block batch size.
 
         Does nothing if the value is already at the maximum.
         """
@@ -59,7 +59,7 @@ def increase(self) -> None:
         self._log(previous_batch_size)
 
     def decrease(self) -> None:
-        """ Decrease the batch size.
+        """Decrease the batch size.
 
         If the current value is already at the minimum raise ``BlockBatchSizeTooSmall``.
         """
@@ -76,7 +76,7 @@ def decrease(self) -> None:
 
     @property
     def batch_size(self) -> BlockNumber:
-        """ Return the current batch size.
+        """Return the current batch size.
 
         Clamps the value to the range given in the config.
         """

raiden/connection_manager.py

@@ -203,7 +203,7 @@ def connect(
                 self._open_channels()
 
     def leave(self, registry_address: TokenNetworkRegistryAddress) -> List[NettingChannelState]:
-        """ Leave the token network.
+        """Leave the token network.
 
         This implies closing all channels and waiting for all channels to be
         settled.
@@ -418,7 +418,7 @@ def _join_partner(self, partner: Address) -> None:
             )
 
     def _open_channels(self) -> bool:
-        """ Open channels until there are `self.initial_channel_target`
+        """Open channels until there are `self.initial_channel_target`
         channels open. Do nothing if there are enough channels open already.
 
         Note: