Fix tests broken in PR #8227. (#8273)

Author: busunkim96

google/cloud/logging/handlers/transports/background_thread.py

@@ -20,6 +20,7 @@
 from __future__ import print_function
 
 import atexit
+import datetime
 import logging
 import sys
 import threading
@@ -261,7 +262,7 @@ def enqueue(
                 "labels": labels,
                 "trace": trace,
                 "span_id": span_id,
-                "timestamp": datetime.utcfromtimestamp(record.created),
+                "timestamp": datetime.datetime.utcfromtimestamp(record.created),
             }
         )
 

tests/unit/handlers/transports/test_background_thread.py

@@ -12,6 +12,7 @@
 # See the License for the specific language governing permissions and
 # limitations under the License.
 
+import time
 import logging
 import unittest
 
@@ -243,7 +244,9 @@ def test__main_thread_terminated_non_empty_queue(self):
         worker = self._make_one(_Logger(self.NAME))
 
         self._start_with_thread_patch(worker)
-        worker.enqueue(mock.Mock(), "")
+        record = mock.Mock()
+        record.created = time.time()
+        worker.enqueue(record, "")
         worker._main_thread_terminated()
 
         self.assertFalse(worker.is_alive)
@@ -253,7 +256,9 @@ def test__main_thread_terminated_did_not_join(self):
 
         self._start_with_thread_patch(worker)
         worker._thread._terminate_on_join = False
-        worker.enqueue(mock.Mock(), "")
+        record = mock.Mock()
+        record.created = time.time()
+        worker.enqueue(record, "")
         worker._main_thread_terminated()
 
         self.assertFalse(worker.is_alive)
@@ -431,6 +436,7 @@ def log_struct(
         labels=None,
         trace=None,
         span_id=None,
+        timestamp=None,
     ):
         from google.cloud.logging.logger import _GLOBAL_RESOURCE