{"payload":{"feedbackUrl":"https://github.com/orgs/community/discussions/53140","repo":{"id":80329712,"defaultBranch":"master","name":"beam","ownerLogin":"igorbernstein2","currentUserCanPush":false,"isFork":true,"isEmpty":false,"createdAt":"2017-01-29T05:07:00.000Z","ownerAvatar":"https://avatars.githubusercontent.com/u/23526194?v=4","public":true,"private":false,"isOrgOwned":false},"refInfo":{"name":"","listCacheKey":"v0:1726252076.0","currentOid":""},"activityList":{"items":[{"before":"4bd5ae63b9c114e0797fad22877b69b0b9700a08","after":"ba8d875646ebd15b6688286e1cd9914febf6caef","ref":"refs/heads/mitigate-early-close","pushedAt":"2024-09-13T21:03:15.000Z","pushType":"push","commitsCount":1,"pusher":{"login":"igorbernstein2","name":"Igor Bernstein","path":"/igorbernstein2","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/23526194?s=80&v=4"},"commit":{"message":"fix warning","shortMessageHtmlLink":"fix warning"}},{"before":"3fa435ae68f03d8b690f2b7294377211577fec26","after":"4bd5ae63b9c114e0797fad22877b69b0b9700a08","ref":"refs/heads/mitigate-early-close","pushedAt":"2024-09-13T20:43:24.000Z","pushType":"push","commitsCount":1,"pusher":{"login":"igorbernstein2","name":"Igor Bernstein","path":"/igorbernstein2","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/23526194?s=80&v=4"},"commit":{"message":"format","shortMessageHtmlLink":"format"}},{"before":"1faf25cdaed8a87cca4fc4a46b3728ebafcb8447","after":"3fa435ae68f03d8b690f2b7294377211577fec26","ref":"refs/heads/mitigate-early-close","pushedAt":"2024-09-13T20:42:37.000Z","pushType":"push","commitsCount":9,"pusher":{"login":"igorbernstein2","name":"Igor Bernstein","path":"/igorbernstein2","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/23526194?s=80&v=4"},"commit":{"message":"Merge branch 'master' into mitigate-early-close","shortMessageHtmlLink":"Merge branch 'master' into mitigate-early-close"}},{"before":"98ad9d2dc0abb8ee5412d6180ea697c027101ae5","after":"1faf25cdaed8a87cca4fc4a46b3728ebafcb8447","ref":"refs/heads/mitigate-early-close","pushedAt":"2024-09-13T20:30:30.000Z","pushType":"push","commitsCount":1,"pusher":{"login":"igorbernstein2","name":"Igor Bernstein","path":"/igorbernstein2","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/23526194?s=80&v=4"},"commit":{"message":"cleanup","shortMessageHtmlLink":"cleanup"}},{"before":"e098092269811dd2ab6f506737c47678b64228eb","after":"98ad9d2dc0abb8ee5412d6180ea697c027101ae5","ref":"refs/heads/mitigate-early-close","pushedAt":"2024-09-13T20:29:12.000Z","pushType":"push","commitsCount":1,"pusher":{"login":"igorbernstein2","name":"Igor Bernstein","path":"/igorbernstein2","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/23526194?s=80&v=4"},"commit":{"message":"use a simpler queue","shortMessageHtmlLink":"use a simpler queue"}},{"before":"85c289baaf0691085bbc4e9c351de96a03466a7e","after":"e098092269811dd2ab6f506737c47678b64228eb","ref":"refs/heads/mitigate-early-close","pushedAt":"2024-09-13T19:42:11.000Z","pushType":"push","commitsCount":1,"pusher":{"login":"igorbernstein2","name":"Igor Bernstein","path":"/igorbernstein2","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/23526194?s=80&v=4"},"commit":{"message":"refactor","shortMessageHtmlLink":"refactor"}},{"before":"1116bf27475c7d8968938d6abb383fe2a431bc51","after":"85c289baaf0691085bbc4e9c351de96a03466a7e","ref":"refs/heads/mitigate-early-close","pushedAt":"2024-09-13T19:39:41.000Z","pushType":"push","commitsCount":1,"pusher":{"login":"igorbernstein2","name":"Igor Bernstein","path":"/igorbernstein2","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/23526194?s=80&v=4"},"commit":{"message":"simplify","shortMessageHtmlLink":"simplify"}},{"before":"8b884b9111330c2e1a9b675787f168aa25c89795","after":"8d8e4b716b37da8e18f1dc7ab5c080a28256f6e1","ref":"refs/heads/fix-synchronization1","pushedAt":"2024-09-13T18:30:52.000Z","pushType":"push","commitsCount":1,"pusher":{"login":"igorbernstein2","name":"Igor Bernstein","path":"/igorbernstein2","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/23526194?s=80&v=4"},"commit":{"message":"format","shortMessageHtmlLink":"format"}},{"before":null,"after":"4e1af10ccc44e7778137456c138dd334083d1547","ref":"refs/heads/fix-except","pushedAt":"2024-09-13T18:27:56.000Z","pushType":"branch_creation","commitsCount":0,"pusher":{"login":"igorbernstein2","name":"Igor Bernstein","path":"/igorbernstein2","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/23526194?s=80&v=4"},"commit":{"message":"fix: ensure that non ApiExceptions in handleMutationException are not swallowed","shortMessageHtmlLink":"fix: ensure that non ApiExceptions in handleMutationException are not…"}},{"before":null,"after":"1116bf27475c7d8968938d6abb383fe2a431bc51","ref":"refs/heads/mitigate-early-close","pushedAt":"2024-09-13T18:25:13.000Z","pushType":"branch_creation","commitsCount":0,"pusher":{"login":"igorbernstein2","name":"Igor Bernstein","path":"/igorbernstein2","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/23526194?s=80&v=4"},"commit":{"message":"fix: ensure that all outstanding future have completed in FinishBundle\n\nPreviously this was done as a side effect of batcher.close. Now we explicitly ensure that all element future have been resolved and any handler errors are propagated","shortMessageHtmlLink":"fix: ensure that all outstanding future have completed in FinishBundle"}},{"before":null,"after":"8b884b9111330c2e1a9b675787f168aa25c89795","ref":"refs/heads/fix-synchronization1","pushedAt":"2024-09-13T17:19:27.000Z","pushType":"branch_creation","commitsCount":0,"pusher":{"login":"igorbernstein2","name":"Igor Bernstein","path":"/igorbernstein2","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/23526194?s=80&v=4"},"commit":{"message":"fix: use threadsafe data structure thats shared between threads\n\nbadRecords gets updated from the gRPC response thread and read from the beam worker's main thread","shortMessageHtmlLink":"fix: use threadsafe data structure thats shared between threads"}},{"before":null,"after":"ed0dbcfcacc79169ef5bee1bfa2958973e938da2","ref":"refs/heads/cbt-client-sharing","pushedAt":"2024-09-09T17:05:59.000Z","pushType":"branch_creation","commitsCount":0,"pusher":{"login":"igorbernstein2","name":"Igor Bernstein","path":"/igorbernstein2","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/23526194?s=80&v=4"},"commit":{"message":"codestyle","shortMessageHtmlLink":"codestyle"}},{"before":"ed0dbcfcacc79169ef5bee1bfa2958973e938da2","after":null,"ref":"refs/heads/cbt-client-sharing","pushedAt":"2024-08-28T19:54:48.000Z","pushType":"branch_deletion","commitsCount":0,"pusher":{"login":"igorbernstein2","name":"Igor Bernstein","path":"/igorbernstein2","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/23526194?s=80&v=4"}},{"before":"edf93e46ffb040b4440fdf0f285d6151c2e73255","after":"ed0dbcfcacc79169ef5bee1bfa2958973e938da2","ref":"refs/heads/cbt-client-sharing","pushedAt":"2024-08-28T16:51:22.000Z","pushType":"push","commitsCount":1,"pusher":{"login":"igorbernstein2","name":"Igor Bernstein","path":"/igorbernstein2","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/23526194?s=80&v=4"},"commit":{"message":"codestyle","shortMessageHtmlLink":"codestyle"}},{"before":"59af471b90bb300e593f1adaf6b4f9e66ec665de","after":"edf93e46ffb040b4440fdf0f285d6151c2e73255","ref":"refs/heads/cbt-client-sharing","pushedAt":"2024-08-28T16:01:31.000Z","pushType":"push","commitsCount":1,"pusher":{"login":"igorbernstein2","name":"Igor Bernstein","path":"/igorbernstein2","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/23526194?s=80&v=4"},"commit":{"message":"codestyle","shortMessageHtmlLink":"codestyle"}},{"before":"0f1d5fc85105c81b5587b2dd354fb1509678bc69","after":"59af471b90bb300e593f1adaf6b4f9e66ec665de","ref":"refs/heads/cbt-client-sharing","pushedAt":"2024-08-28T16:01:03.000Z","pushType":"push","commitsCount":1,"pusher":{"login":"igorbernstein2","name":"Igor Bernstein","path":"/igorbernstein2","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/23526194?s=80&v=4"},"commit":{"message":"codestyle","shortMessageHtmlLink":"codestyle"}},{"before":"a4d5c4c54660a9bd8de1423181e733363607e742","after":"0f1d5fc85105c81b5587b2dd354fb1509678bc69","ref":"refs/heads/cbt-client-sharing","pushedAt":"2024-08-28T15:41:12.000Z","pushType":"push","commitsCount":1,"pusher":{"login":"igorbernstein2","name":"Igor Bernstein","path":"/igorbernstein2","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/23526194?s=80&v=4"},"commit":{"message":"codestyle","shortMessageHtmlLink":"codestyle"}},{"before":"3d64d4f12e7fa6374377f723d7c98729f815cf5c","after":"a4d5c4c54660a9bd8de1423181e733363607e742","ref":"refs/heads/cbt-client-sharing","pushedAt":"2024-08-28T14:46:53.000Z","pushType":"push","commitsCount":1,"pusher":{"login":"igorbernstein2","name":"Igor Bernstein","path":"/igorbernstein2","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/23526194?s=80&v=4"},"commit":{"message":"- force bundle creation by using an unbounded source with a rate\n- fix warnings about metrics\n- add a sanity check for client cleanup","shortMessageHtmlLink":"- force bundle creation by using an unbounded source with a rate"}},{"before":"68b01291089cd2f3348504ae1cf259ab7133aa3c","after":"3d64d4f12e7fa6374377f723d7c98729f815cf5c","ref":"refs/heads/cbt-client-sharing","pushedAt":"2024-08-27T23:45:02.000Z","pushType":"push","commitsCount":1,"pusher":{"login":"igorbernstein2","name":"Igor Bernstein","path":"/igorbernstein2","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/23526194?s=80&v=4"},"commit":{"message":"get the test passing","shortMessageHtmlLink":"get the test passing"}},{"before":"8932dac47f14364e1a83623c0ebb011141547c46","after":"68b01291089cd2f3348504ae1cf259ab7133aa3c","ref":"refs/heads/cbt-client-sharing","pushedAt":"2024-08-27T22:21:24.000Z","pushType":"push","commitsCount":1,"pusher":{"login":"igorbernstein2","name":"Igor Bernstein","path":"/igorbernstein2","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/23526194?s=80&v=4"},"commit":{"message":"fix class name","shortMessageHtmlLink":"fix class name"}},{"before":"c6cd22ea48afb71be8fb4c11c0be500bbfb85ab0","after":"8932dac47f14364e1a83623c0ebb011141547c46","ref":"refs/heads/cbt-client-sharing","pushedAt":"2024-08-27T20:45:40.000Z","pushType":"push","commitsCount":1,"pusher":{"login":"igorbernstein2","name":"Igor Bernstein","path":"/igorbernstein2","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/23526194?s=80&v=4"},"commit":{"message":"checkstyle","shortMessageHtmlLink":"checkstyle"}},{"before":"b42274caf9a22225022cacdb5e87a6e8b3f2e735","after":"c6cd22ea48afb71be8fb4c11c0be500bbfb85ab0","ref":"refs/heads/cbt-client-sharing","pushedAt":"2024-08-27T20:28:29.000Z","pushType":"push","commitsCount":1,"pusher":{"login":"igorbernstein2","name":"Igor Bernstein","path":"/igorbernstein2","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/23526194?s=80&v=4"},"commit":{"message":"spotlessApply","shortMessageHtmlLink":"spotlessApply"}},{"before":"06c6f3f35c6b819a45378fd9a07778391e1a64a2","after":"b42274caf9a22225022cacdb5e87a6e8b3f2e735","ref":"refs/heads/cbt-client-sharing","pushedAt":"2024-08-27T19:51:31.000Z","pushType":"push","commitsCount":2,"pusher":{"login":"igorbernstein2","name":"Igor Bernstein","path":"/igorbernstein2","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/23526194?s=80&v=4"},"commit":{"message":"code style","shortMessageHtmlLink":"code style"}},{"before":null,"after":"06c6f3f35c6b819a45378fd9a07778391e1a64a2","ref":"refs/heads/cbt-client-sharing","pushedAt":"2024-08-27T19:36:56.000Z","pushType":"branch_creation","commitsCount":0,"pusher":{"login":"igorbernstein2","name":"Igor Bernstein","path":"/igorbernstein2","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/23526194?s=80&v=4"},"commit":{"message":"Fix BigtableIO.write() client sharing\n\nThis PR expands the refcount lease on the underlying Bigtable client from Start/StopBundle to the first StartBundle until Teardown. The previous behavior had a client & connection churn when all worker threads had similar load.","shortMessageHtmlLink":"Fix BigtableIO.write() client sharing"}}],"hasNextPage":false,"hasPreviousPage":false,"activityType":"all","actor":null,"timePeriod":"all","sort":"DESC","perPage":30,"cursor":"Y3Vyc29yOnYyOpK7MjAyNC0wOS0xM1QyMTowMzoxNS4wMDAwMDBazwAAAAS14qRd","startCursor":"Y3Vyc29yOnYyOpK7MjAyNC0wOS0xM1QyMTowMzoxNS4wMDAwMDBazwAAAAS14qRd","endCursor":"Y3Vyc29yOnYyOpK7MjAyNC0wOC0yN1QxOTozNjo1Ni4wMDAwMDBazwAAAASlwRdD"}},"title":"Activity · igorbernstein2/beam"}