Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

feat: set partial_success to default to true for batched logs #649

Merged
merged 7 commits into from
Oct 17, 2022
Merged

feat: set partial_success to default to true for batched logs #649

Show file tree
Hide file tree
Changes from 1 commit
Commits
Show all changes
7 commits
Select commit Hold shift + click to select a range
00dd76c
set partial_success to default to true for batched logs
daniel-sanche Oct 11, 2022
dfdc92a
changed default partial success value for http
daniel-sanche Oct 11, 2022
1355a63
Merge branch 'main' into partial_success
daniel-sanche Oct 17, 2022
035ea7f
🦉 Updates from OwlBot post-processor
gcf-owl-bot[bot] Oct 17, 2022
2748b0d
fixed http tests
daniel-sanche Oct 17, 2022
38268f1
ran blacken
daniel-sanche Oct 17, 2022
252ec5b
Merge branch 'partial_success' of github.com:googleapis/python-loggin…
daniel-sanche Oct 17, 2022
File filter

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Prev Previous commit
Next Next commit
🦉 Updates from OwlBot post-processor 
See https://github.com/googleapis/repo-automation-bots/blob/main/packages/owl-bot/README.md
  • Loading branch information
@gcf-owl-bot
gcf-owl-bot[bot] committed Oct 17, 2022
commit 035ea7f1f51fa2f16dd387ef00e654cac3b09276
4 changes: 3 additions & 1 deletion google/cloud/logging_v2/logger.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -460,5 +460,7 @@ def commit(self, *, client=None, partial_success=True):

entries = [entry.to_api_repr() for entry in self.entries]

client.logging_api.write_entries(entries, partial_success=partial_success, **kwargs)
client.logging_api.write_entries(
entries, partial_success=partial_success, **kwargs
)
del self.entries[:]
94 changes: 71 additions & 23 deletions tests/unit/test_logger.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -123,7 +123,9 @@ def test_log_empty_defaults_w_default_labels(self):

logger.log_empty()

self.assertEqual(api._write_entries_called_with, (ENTRIES, None, None, None, True))
self.assertEqual(
api._write_entries_called_with, (ENTRIES, None, None, None, True)
)

def test_log_empty_w_explicit(self):
import datetime
Expand Down Expand Up @@ -177,7 +179,9 @@ def test_log_empty_w_explicit(self):
trace_sampled=True,
)

self.assertEqual(api._write_entries_called_with, (ENTRIES, None, None, None, True))
self.assertEqual(
api._write_entries_called_with, (ENTRIES, None, None, None, True)
)

def test_log_text_defaults(self):
from google.cloud.logging_v2.handlers._monitored_resources import (
Expand All @@ -199,7 +203,9 @@ def test_log_text_defaults(self):

logger.log_text(TEXT)

self.assertEqual(api._write_entries_called_with, (ENTRIES, None, None, None, True))
self.assertEqual(
api._write_entries_called_with, (ENTRIES, None, None, None, True)
)

def test_log_text_w_unicode_and_default_labels(self):
from google.cloud.logging_v2.handlers._monitored_resources import (
Expand All @@ -223,7 +229,9 @@ def test_log_text_w_unicode_and_default_labels(self):

logger.log_text(TEXT)

self.assertEqual(api._write_entries_called_with, (ENTRIES, None, None, None, True))
self.assertEqual(
api._write_entries_called_with, (ENTRIES, None, None, None, True)
)

def test_log_text_explicit(self):
import datetime
Expand Down Expand Up @@ -280,7 +288,9 @@ def test_log_text_explicit(self):
trace_sampled=True,
)

self.assertEqual(api._write_entries_called_with, (ENTRIES, None, None, None, True))
self.assertEqual(
api._write_entries_called_with, (ENTRIES, None, None, None, True)
)

def test_log_struct_defaults(self):
from google.cloud.logging_v2.handlers._monitored_resources import (
Expand All @@ -302,7 +312,9 @@ def test_log_struct_defaults(self):

logger.log_struct(STRUCT)

self.assertEqual(api._write_entries_called_with, (ENTRIES, None, None, None, True))
self.assertEqual(
api._write_entries_called_with, (ENTRIES, None, None, None, True)
)

def test_log_nested_struct(self):
from google.cloud.logging_v2.handlers._monitored_resources import (
Expand All @@ -324,7 +336,9 @@ def test_log_nested_struct(self):

logger.log(STRUCT)

self.assertEqual(api._write_entries_called_with, (ENTRIES, None, None, None, True))
self.assertEqual(
api._write_entries_called_with, (ENTRIES, None, None, None, True)
)

def test_log_struct_w_default_labels(self):
from google.cloud.logging_v2.handlers._monitored_resources import (
Expand All @@ -348,7 +362,9 @@ def test_log_struct_w_default_labels(self):

logger.log_struct(STRUCT)

self.assertEqual(api._write_entries_called_with, (ENTRIES, None, None, None, True))
self.assertEqual(
api._write_entries_called_with, (ENTRIES, None, None, None, True)
)

def test_log_struct_w_explicit(self):
import datetime
Expand Down Expand Up @@ -405,7 +421,9 @@ def test_log_struct_w_explicit(self):
trace_sampled=True,
)

self.assertEqual(api._write_entries_called_with, (ENTRIES, None, None, None, True))
self.assertEqual(
api._write_entries_called_with, (ENTRIES, None, None, None, True)
)

def test_log_struct_inference(self):
"""
Expand Down Expand Up @@ -439,7 +457,9 @@ def test_log_struct_inference(self):

logger.log_struct(STRUCT, resource=RESOURCE)

self.assertEqual(api._write_entries_called_with, (ENTRIES, None, None, None, True))
self.assertEqual(
api._write_entries_called_with, (ENTRIES, None, None, None, True)
)

def test_log_w_dict_resource(self):
"""
Expand Down Expand Up @@ -467,7 +487,9 @@ def test_log_w_dict_resource(self):
}
]
logger.log(MESSAGE, resource=resource)
self.assertEqual(api._write_entries_called_with, (ENTRIES, None, None, None, True))
self.assertEqual(
api._write_entries_called_with, (ENTRIES, None, None, None, True)
)

def test_log_lowercase_severity(self):
"""
Expand Down Expand Up @@ -530,7 +552,9 @@ def test_log_proto_defaults(self):

logger.log_proto(message)

self.assertEqual(api._write_entries_called_with, (ENTRIES, None, None, None, True))
self.assertEqual(
api._write_entries_called_with, (ENTRIES, None, None, None, True)
)

def test_log_proto_w_default_labels(self):
from google.cloud.logging_v2.handlers._monitored_resources import (
Expand All @@ -556,7 +580,9 @@ def test_log_proto_w_default_labels(self):

logger.log_proto(message)

self.assertEqual(api._write_entries_called_with, (ENTRIES, None, None, None, True))
self.assertEqual(
api._write_entries_called_with, (ENTRIES, None, None, None, True)
)

def test_log_proto_w_explicit(self):
import json
Expand Down Expand Up @@ -617,7 +643,9 @@ def test_log_proto_w_explicit(self):
trace_sampled=True,
)

self.assertEqual(api._write_entries_called_with, (ENTRIES, None, None, None, True))
self.assertEqual(
api._write_entries_called_with, (ENTRIES, None, None, None, True)
)

def test_log_inference_empty(self):
from google.cloud.logging_v2.handlers._monitored_resources import (
Expand All @@ -638,7 +666,9 @@ def test_log_inference_empty(self):

logger.log()

self.assertEqual(api._write_entries_called_with, (ENTRIES, None, None, None, True))
self.assertEqual(
api._write_entries_called_with, (ENTRIES, None, None, None, True)
)

def test_log_inference_text(self):
from google.cloud.logging_v2.handlers._monitored_resources import (
Expand All @@ -659,7 +689,9 @@ def test_log_inference_text(self):

logger.log(TEXT)

self.assertEqual(api._write_entries_called_with, (ENTRIES, None, None, None, True))
self.assertEqual(
api._write_entries_called_with, (ENTRIES, None, None, None, True)
)

def test_log_inference_struct(self):
from google.cloud.logging_v2.handlers._monitored_resources import (
Expand All @@ -680,7 +712,9 @@ def test_log_inference_struct(self):

logger.log(STRUCT)

self.assertEqual(api._write_entries_called_with, (ENTRIES, None, None, None, True))
self.assertEqual(
api._write_entries_called_with, (ENTRIES, None, None, None, True)
)

def test_log_inference_proto(self):
import json
Expand All @@ -704,7 +738,9 @@ def test_log_inference_proto(self):

logger.log(message)

self.assertEqual(api._write_entries_called_with, (ENTRIES, None, None, None, True))
self.assertEqual(
api._write_entries_called_with, (ENTRIES, None, None, None, True)
)

def test_delete_w_bound_client(self):
client = _Client(project=self.PROJECT)
Expand Down Expand Up @@ -1033,12 +1069,16 @@ def test_first_log_emits_instrumentation(self):
api = client.logging_api = _DummyLoggingAPI()
logger = self._make_one(self.LOGGER_NAME, client=client, labels=DEFAULT_LABELS)
logger.log_empty()
self.assertEqual(api._write_entries_called_with, (ENTRIES, None, None, None, True))
self.assertEqual(
api._write_entries_called_with, (ENTRIES, None, None, None, True)
)

ENTRIES = ENTRIES[-1:]
api = client.logging_api = _DummyLoggingAPI()
logger.log_empty()
self.assertEqual(api._write_entries_called_with, (ENTRIES, None, None, None, True))
self.assertEqual(
api._write_entries_called_with, (ENTRIES, None, None, None, True)
)


class TestBatch(unittest.TestCase):
Expand Down Expand Up @@ -1436,7 +1476,8 @@ def test_commit_w_unknown_entry_type(self):

self.assertEqual(list(batch.entries), [])
self.assertEqual(
api._write_entries_called_with, ([ENTRY], logger.full_name, None, None, True)
api._write_entries_called_with,
([ENTRY], logger.full_name, None, None, True),
)

def test_commit_w_resource_specified(self):
Expand Down Expand Up @@ -1550,7 +1591,8 @@ def test_commit_w_bound_client(self):

self.assertEqual(list(batch.entries), [])
self.assertEqual(
api._write_entries_called_with, (ENTRIES, logger.full_name, None, None, True)
api._write_entries_called_with,
(ENTRIES, logger.full_name, None, None, True),
)

def test_commit_w_alternate_client(self):
Expand Down Expand Up @@ -1719,7 +1761,13 @@ def write_entries(
labels=None,
partial_success=False,
):
self._write_entries_called_with = (entries, logger_name, resource, labels, partial_success)
self._write_entries_called_with = (
entries,
logger_name,
resource,
labels,
partial_success,
)

def logger_delete(self, logger_name):
self._logger_delete_called_with = logger_name
Expand Down