Auto-generated patch by python-black

[integration/test.git] / tools / clustering / cluster-debugging / transaction-tracking / process.py

diff --git a/tools/clustering/cluster-debugging/transaction-tracking/process.py b/tools/clustering/cluster-debugging/transaction-tracking/process.py
index 92678d14b12ad71cf24189da6497add1740bcbad..cbceca4acf3cdb5e8996b482e55a2d98ec58dc18 100644 (file)
--- a/tools/clustering/cluster-debugging/transaction-tracking/process.py
+++ b/tools/clustering/cluster-debugging/transaction-tracking/process.py
@@ -8,18 +8,15 @@ class Transaction:
     def __init__(self, txnId, startTime, operations):
         self.txnId = txnId
         self.operations = operations
-        self.startTime = datetime.strptime(startTime,
-                                           '%Y-%m-%d,%H:%M:%S,%f')
+        self.startTime = datetime.strptime(startTime, "%Y-%m-%d,%H:%M:%S,%f")
         self.reachedTime = None
         self.completeTime = None
 
     def setReachedTime(self, reachedTime):
-        self.reachedTime = datetime.strptime(reachedTime,
-                                             '%Y-%m-%d,%H:%M:%S,%f')
+        self.reachedTime = datetime.strptime(reachedTime, "%Y-%m-%d,%H:%M:%S,%f")
 
     def setCompleteTime(self, completeTime):
-        self.completeTime = datetime.strptime(completeTime,
-                                              '%Y-%m-%d,%H:%M:%S,%f')
+        self.completeTime = datetime.strptime(completeTime, "%Y-%m-%d,%H:%M:%S,%f")
 
     def totalTime(self):
         return Transaction.diffInMicros(self.startTime, self.completeTime)
@@ -37,25 +34,45 @@ class Transaction:
         return -1
 
     def __str__(self):
-        return "transactionId = " + self.txnId + ", " \
-               + "operations = " + unicode(self.operations) + ", " \
-               + "startTime = " + unicode(self.startTime) + ", " \
-               + "reachedTime = " + unicode(self.reachedTime) + ", " \
-               + "completeTime = " + unicode(self.completeTime) + ", " \
-               + "transferTime = " + unicode(self.transferTime()) + ", " \
-               + "totalTime = " + unicode(self.totalTime())
+        return (
+            "transactionId = "
+            + self.txnId
+            + ", "
+            + "operations = "
+            + unicode(self.operations)
+            + ", "
+            + "startTime = "
+            + unicode(self.startTime)
+            + ", "
+            + "reachedTime = "
+            + unicode(self.reachedTime)
+            + ", "
+            + "completeTime = "
+            + unicode(self.completeTime)
+            + ", "
+            + "transferTime = "
+            + unicode(self.transferTime())
+            + ", "
+            + "totalTime = "
+            + unicode(self.totalTime())
+        )
 
     def csv(self):
-        return unicode(self.startTime) + "," \
-            + self.txnId + "," \
-            + unicode(self.operations) + "," \
-            + unicode(self.transferTime()) + "," \
+        return (
+            unicode(self.startTime)
+            + ","
+            + self.txnId
+            + ","
+            + unicode(self.operations)
+            + ","
+            + unicode(self.transferTime())
+            + ","
             + unicode(self.totalTime())
+        )
 
     @staticmethod
     def csv_header():
-        return "Start Time,Transaction Id,Operations,Transfer Time," \
-               "Complete Time"
+        return "Start Time,Transaction Id,Operations,Transfer Time," "Complete Time"
 
 
 def processFiles():
@@ -63,9 +80,9 @@ def processFiles():
     txnBegin = open("txnbegin.txt", "r")
     for line in txnBegin:
         arr = line.split(",")
-        txns[arr[3]] = Transaction(arr[3],
-                                   arr[0] + "," + arr[1] + "," + arr[2],
-                                   int(arr[4]))
+        txns[arr[3]] = Transaction(
+            arr[3], arr[0] + "," + arr[1] + "," + arr[2], int(arr[4])
+        )
 
     txnReached = open("txnreached.txt", "r")
     for line in txnReached: