Keep timestamp precision when encoding protobuf
Previously, the task would return with an ETA precision of only
seconds.
@@ -210,7 +210,7 @@ class Task(object):
task_pb.set_task_name(self.id)
epoch = datetime.datetime.utcfromtimestamp(0)
task_pb.set_eta_usec(
- int((self.get_eta() - epoch).total_seconds()) * 1000000)
+ int((self.get_eta() - epoch).total_seconds() * 1000000))
task_pb.set_retry_count(self.retry_count)
task_pb.set_body(base64.urlsafe_b64decode(self.payloadBase64))
try:
