{"payload":{"feedbackUrl":"https://github.com/orgs/community/discussions/53140","repo":{"id":240173596,"defaultBranch":"master","name":"flow","ownerLogin":"estuary","currentUserCanPush":false,"isFork":false,"isEmpty":false,"createdAt":"2020-02-13T04:05:14.000Z","ownerAvatar":"https://avatars.githubusercontent.com/u/59032085?v=4","public":true,"private":false,"isOrgOwned":true},"refInfo":{"name":"","listCacheKey":"v0:1726771052.0","currentOid":""},"activityList":{"items":[{"before":"96653f0a697222c5d58a2d5c98862c3aebf00341","after":"000a3a084a6ffa02170817b089cc6a5de46d5786","ref":"refs/heads/jshearer/dekaf_materialization_endpoint","pushedAt":"2024-09-19T20:08:34.000Z","pushType":"force_push","commitsCount":0,"pusher":{"login":"jshearer","name":"Joseph Shearer","path":"/jshearer","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/4368270?s=80&v=4"},"commit":{"message":"crates/activate: Dekaf materializations should not get shards or recovery journals, but they _should_ get ops stats+logs collections","shortMessageHtmlLink":"crates/activate: Dekaf materializations should not get shards or reco…"}},{"before":"c2ba6744bd454d1dc87614ac937655b408c4b4f7","after":"96653f0a697222c5d58a2d5c98862c3aebf00341","ref":"refs/heads/jshearer/dekaf_materialization_endpoint","pushedAt":"2024-09-19T18:22:31.000Z","pushType":"force_push","commitsCount":0,"pusher":{"login":"jshearer","name":"Joseph Shearer","path":"/jshearer","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/4368270?s=80&v=4"},"commit":{"message":"crates/activate: Dekaf materializations should not get shards or recovery journals, but they _should_ get ops stats+logs collections","shortMessageHtmlLink":"crates/activate: Dekaf materializations should not get shards or reco…"}},{"before":"8c314dd63742af00728fb1ec0e25f5b647eb2b33","after":"ee15c0bd6f5d5da9820a1d7f435737792695f3b9","ref":"refs/heads/master","pushedAt":"2024-09-19T18:18:06.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"jshearer","name":"Joseph Shearer","path":"/jshearer","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/4368270?s=80&v=4"},"commit":{"message":"dekaf: Gracefully handle invalid connection attempts without shutting down the whole server","shortMessageHtmlLink":"dekaf: Gracefully handle invalid connection attempts without shutting…"}},{"before":"095f224bc7fa8a40bac93565e764173f74a2de86","after":null,"ref":"refs/heads/phil/touch-pub-cleanups","pushedAt":"2024-09-19T18:03:41.000Z","pushType":"branch_deletion","commitsCount":0,"pusher":{"login":"psFried","name":"Phil Fried","path":"/psFried","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/4495829?s=80&v=4"}},{"before":"9a3565a36e10e5b4ff14409c0281dbb355617894","after":"d517871be3105cf3e368b47d9c53e8f37d268d92","ref":"refs/heads/jshearer/dekaf_tls_fixes","pushedAt":"2024-09-19T17:57:15.000Z","pushType":"force_push","commitsCount":0,"pusher":{"login":"jshearer","name":"Joseph Shearer","path":"/jshearer","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/4368270?s=80&v=4"},"commit":{"message":"dekaf: Gracefully handle invalid connection attempts without shutting down the whole server","shortMessageHtmlLink":"dekaf: Gracefully handle invalid connection attempts without shutting…"}},{"before":"c90b6fdc44dc87743f4966f59f3968e0f4762c44","after":"8c314dd63742af00728fb1ec0e25f5b647eb2b33","ref":"refs/heads/master","pushedAt":"2024-09-19T17:39:59.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"psFried","name":"Phil Fried","path":"/psFried","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/4495829?s=80&v=4"},"commit":{"message":"agent: use new pub_id when evolving materializations\n\nEnsure that the materialization controller will always use a new\npublication id when applying onIncompatibleSchemaChange actions.\nPreviously, it would re-use the publication id of the one that had\nfailed. That doesn't work if the failed publication was a \"touch\"\npublication. Applying `onIncompatibleSchemaChange` actions modifies the\nmodel, and so the publication id must be greater than `last_pub_id`.\nGenerating a new id ensures that is always the case.","shortMessageHtmlLink":"agent: use new pub_id when evolving materializations"}},{"before":null,"after":"095f224bc7fa8a40bac93565e764173f74a2de86","ref":"refs/heads/phil/touch-pub-cleanups","pushedAt":"2024-09-19T16:59:44.000Z","pushType":"branch_creation","commitsCount":0,"pusher":{"login":"psFried","name":"Phil Fried","path":"/psFried","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/4495829?s=80&v=4"},"commit":{"message":"agent: use new pub_id when evolving materializations\n\nEnsure that the materialization controller will always use a new\npublication id when applying onIncompatibleSchemaChange actions.\nPreviously, it would re-use the publication id of the one that had\nfailed. That doesn't work if the failed publication was a \"touch\"\npublication. Applying `onIncompatibleSchemaChange` actions modifies the\nmodel, and so the publication id must be greater than `last_pub_id`.\nGenerating a new id ensures that is always the case.","shortMessageHtmlLink":"agent: use new pub_id when evolving materializations"}},{"before":"34c11f1740191ec3857869f621b54ec4a9287e4e","after":"c2ba6744bd454d1dc87614ac937655b408c4b4f7","ref":"refs/heads/jshearer/dekaf_materialization_endpoint","pushedAt":"2024-09-19T16:44:00.000Z","pushType":"push","commitsCount":1,"pusher":{"login":"jshearer","name":"Joseph Shearer","path":"/jshearer","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/4368270?s=80&v=4"},"commit":{"message":"crates/activate: Dekaf materializations should not get shards or recovery journals, but they _should_ get ops stats+logs collections","shortMessageHtmlLink":"crates/activate: Dekaf materializations should not get shards or reco…"}},{"before":"44357291ce124000fd59e8ebb1ad5c8c84fdfe4a","after":null,"ref":"refs/heads/phil/source-capture-pub-fix","pushedAt":"2024-09-19T12:38:07.000Z","pushType":"branch_deletion","commitsCount":0,"pusher":{"login":"psFried","name":"Phil Fried","path":"/psFried","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/4495829?s=80&v=4"}},{"before":"2e904fba25c387dd4f4ca356719d61c69ba5ddb3","after":"c90b6fdc44dc87743f4966f59f3968e0f4762c44","ref":"refs/heads/master","pushedAt":"2024-09-19T12:38:04.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"psFried","name":"Phil Fried","path":"/psFried","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/4495829?s=80&v=4"},"commit":{"message":"agent: fix materialization sourceCapture updates\n\nWhen updating the materialization spec in response to new bindings on\nthe `sourceCapture`, ensure that `is_touch` is set to false. Otherwise,\nthe publication will fail because the model has been changed.","shortMessageHtmlLink":"agent: fix materialization sourceCapture updates"}},{"before":null,"after":"44357291ce124000fd59e8ebb1ad5c8c84fdfe4a","ref":"refs/heads/phil/source-capture-pub-fix","pushedAt":"2024-09-19T11:40:43.000Z","pushType":"branch_creation","commitsCount":0,"pusher":{"login":"psFried","name":"Phil Fried","path":"/psFried","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/4495829?s=80&v=4"},"commit":{"message":"agent: fix materialization sourceCapture updates\n\nWhen updating the materialization spec in response to new bindings on\nthe `sourceCapture`, ensure that `is_touch` is set to false. Otherwise,\nthe publication will fail because the model has been changed.","shortMessageHtmlLink":"agent: fix materialization sourceCapture updates"}},{"before":"3594a3dd67a66c5a1023e4b56694df4a0bbe8978","after":"7c122450f1e25c40025b782bb449ab8ece4c899a","ref":"refs/heads/mahdi/x-task-name","pushedAt":"2024-09-19T11:05:40.000Z","pushType":"force_push","commitsCount":0,"pusher":{"login":"mdibaiee","name":"Mahdi Dibaiee","path":"/mdibaiee","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/2807772?s=80&v=4"},"commit":{"message":"agent: rename SourceCapture's schemaMode to targetSchema","shortMessageHtmlLink":"agent: rename SourceCapture's schemaMode to targetSchema"}},{"before":"7cb8c301fed87f87c18d309b556e1c19d6a102ab","after":"3594a3dd67a66c5a1023e4b56694df4a0bbe8978","ref":"refs/heads/mahdi/x-task-name","pushedAt":"2024-09-19T09:10:37.000Z","pushType":"force_push","commitsCount":0,"pusher":{"login":"mdibaiee","name":"Mahdi Dibaiee","path":"/mdibaiee","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/2807772?s=80&v=4"},"commit":{"message":"agent: rename SourceCapture's schemaMode to targetSchema","shortMessageHtmlLink":"agent: rename SourceCapture's schemaMode to targetSchema"}},{"before":null,"after":"34c11f1740191ec3857869f621b54ec4a9287e4e","ref":"refs/heads/jshearer/dekaf_materialization_endpoint","pushedAt":"2024-09-18T21:22:32.000Z","pushType":"branch_creation","commitsCount":0,"pusher":{"login":"jshearer","name":"Joseph Shearer","path":"/jshearer","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/4368270?s=80&v=4"},"commit":{"message":"dekaf: Introduce `MaterializationEndpoint::Dekaf`\n\nA materialization of this kind is purely descriptive, and cannot be directly started. It is used to convey the intent to expose a set of bindings through Dekaf, which will look it up to determine things like binding names and field selection/projections.","shortMessageHtmlLink":"dekaf: Introduce <code>MaterializationEndpoint::Dekaf</code>"}},{"before":"bae42ad41464578f79ca05b870c2b2779f05fb93","after":null,"ref":"refs/heads/jshearer/batch_drafts","pushedAt":"2024-09-18T21:10:05.000Z","pushType":"branch_deletion","commitsCount":0,"pusher":{"login":"jshearer","name":"Joseph Shearer","path":"/jshearer","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/4368270?s=80&v=4"}},{"before":"e127a5c1794ce4935565f9004ea72d7adc19092e","after":null,"ref":"refs/heads/jshearer/dekaf_gmp","pushedAt":"2024-09-18T21:10:04.000Z","pushType":"branch_deletion","commitsCount":0,"pusher":{"login":"jshearer","name":"Joseph Shearer","path":"/jshearer","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/4368270?s=80&v=4"}},{"before":"bc73e197404f77f942061fb8521437583fc17f4e","after":null,"ref":"refs/heads/jshearer/pagination_boundary_fix","pushedAt":"2024-09-18T17:04:45.000Z","pushType":"branch_deletion","commitsCount":0,"pusher":{"login":"jgraettinger","name":"Johnny Graettinger","path":"/jgraettinger","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/209664?s=80&v=4"}},{"before":null,"after":"9a3565a36e10e5b4ff14409c0281dbb355617894","ref":"refs/heads/jshearer/dekaf_tls_fixes","pushedAt":"2024-09-18T16:41:05.000Z","pushType":"branch_creation","commitsCount":0,"pusher":{"login":"jshearer","name":"Joseph Shearer","path":"/jshearer","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/4368270?s=80&v=4"},"commit":{"message":"dekaf: Gracefully handle invalid connection attempts without shutting down the whole server","shortMessageHtmlLink":"dekaf: Gracefully handle invalid connection attempts without shutting…"}},{"before":"1c40d8bfb1d84c6e0feda9e88e46e773e488ec0c","after":"7cb8c301fed87f87c18d309b556e1c19d6a102ab","ref":"refs/heads/mahdi/x-task-name","pushedAt":"2024-09-18T16:36:47.000Z","pushType":"push","commitsCount":1,"pusher":{"login":"mdibaiee","name":"Mahdi Dibaiee","path":"/mdibaiee","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/2807772?s=80&v=4"},"commit":{"message":"agent: rename SourceCapture's schemaMode to targetSchema","shortMessageHtmlLink":"agent: rename SourceCapture's schemaMode to targetSchema"}},{"before":"9d65aa59a8a74fa73a985bf21a4461459cf222ba","after":"2e904fba25c387dd4f4ca356719d61c69ba5ddb3","ref":"refs/heads/master","pushedAt":"2024-09-18T16:22:06.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"jshearer","name":"Joseph Shearer","path":"/jshearer","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/4368270?s=80&v=4"},"commit":{"message":"flowctl: Keep track of next page offset considering that responses may sometimes include more than `page_size` rows","shortMessageHtmlLink":"flowctl: Keep track of next page offset considering that responses ma…"}},{"before":"60fa17e18b482ecda271ba4586ec65927ec3cf5d","after":"bc73e197404f77f942061fb8521437583fc17f4e","ref":"refs/heads/jshearer/pagination_boundary_fix","pushedAt":"2024-09-18T16:14:24.000Z","pushType":"force_push","commitsCount":0,"pusher":{"login":"jshearer","name":"Joseph Shearer","path":"/jshearer","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/4368270?s=80&v=4"},"commit":{"message":"flowctl: Keep track of next page offset considering that responses may sometimes include more than `page_size` rows","shortMessageHtmlLink":"flowctl: Keep track of next page offset considering that responses ma…"}},{"before":"9d83b1ed8fc5ead8699cc39dc002e4e922090181","after":"60fa17e18b482ecda271ba4586ec65927ec3cf5d","ref":"refs/heads/jshearer/pagination_boundary_fix","pushedAt":"2024-09-18T15:59:18.000Z","pushType":"force_push","commitsCount":0,"pusher":{"login":"jshearer","name":"Joseph Shearer","path":"/jshearer","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/4368270?s=80&v=4"},"commit":{"message":"flowctl: Keep track of next page offset considering that responses may sometimes include more than `page_size` rows","shortMessageHtmlLink":"flowctl: Keep track of next page offset considering that responses ma…"}},{"before":"1ebba9c97ea0abd99f9e171a673192b0038f429a","after":"9d83b1ed8fc5ead8699cc39dc002e4e922090181","ref":"refs/heads/jshearer/pagination_boundary_fix","pushedAt":"2024-09-18T15:55:28.000Z","pushType":"force_push","commitsCount":0,"pusher":{"login":"jshearer","name":"Joseph Shearer","path":"/jshearer","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/4368270?s=80&v=4"},"commit":{"message":"flowctl: Keep track of next page offset considering that responses may sometimes include more than `page_size` rows","shortMessageHtmlLink":"flowctl: Keep track of next page offset considering that responses ma…"}},{"before":null,"after":"1ebba9c97ea0abd99f9e171a673192b0038f429a","ref":"refs/heads/jshearer/pagination_boundary_fix","pushedAt":"2024-09-18T15:48:34.000Z","pushType":"branch_creation","commitsCount":0,"pusher":{"login":"jshearer","name":"Joseph Shearer","path":"/jshearer","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/4368270?s=80&v=4"},"commit":{"message":"flowctl: Keep track of next page offset considering that responses may sometimes include more than `page_size` rows","shortMessageHtmlLink":"flowctl: Keep track of next page offset considering that responses ma…"}},{"before":"03f0e7670507038f59c95a4bbe2e1e539eaaf591","after":"ca30917426af64b10246ecc97ec63d155351fdb6","ref":"refs/heads/johnny/dpg","pushedAt":"2024-09-17T20:35:42.000Z","pushType":"force_push","commitsCount":0,"pusher":{"login":"jgraettinger","name":"Johnny Graettinger","path":"/jgraettinger","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/209664?s=80&v=4"},"commit":{"message":"flowctl: refactor config and support new collection & task authorizations\n\nThis change introduces the agent API to `flowctl`, which is the\nproverbial straw which motivated a deeper refactor of flowctl\nconfiguration.\n\nAs a headline feature, `flowctl` supports the new task and collection\nauthorization APIs and uses them in support of serving existing\nsubcommands for reading collections, previews, and read ops logs or\nstats.\n\nClean up management of access and refresh tokens by obtaining access\ntokens or generating refresh tokens prior to calling into a particular\nsub-command. Preserve the ability to run `flowctl` in an unauthenticated\nmode.\n\nMake it easier to use `flowctl` against a local stack by introducing\nalternative defaults when running under a \"local\" profile.\n\nAlso fix handling of single-use refresh tokens, where we must retain the\nupdated secret after using it to generate a new access token. We could\nnow consider having `flowctl` create single-use refresh tokens rather\nthan multi-use ones, but I didn't want to take that step just yet.\n\nAlso fix mis-ordering of output when reading journals.\n\nAlso fix OffsetNotYetAvailable error when reading a journal in non-blocking mode.\n\nIssue #1627","shortMessageHtmlLink":"flowctl: refactor config and support new collection &amp; task authorizat…"}},{"before":"70c9d98f50296f10ed88ba1dd1ce326239996569","after":"1c40d8bfb1d84c6e0feda9e88e46e773e488ec0c","ref":"refs/heads/mahdi/x-task-name","pushedAt":"2024-09-17T19:22:14.000Z","pushType":"force_push","commitsCount":0,"pusher":{"login":"mdibaiee","name":"Mahdi Dibaiee","path":"/mdibaiee","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/2807772?s=80&v=4"},"commit":{"message":"agent: refactoring SourceCapture and SourceCaptureDef","shortMessageHtmlLink":"agent: refactoring SourceCapture and SourceCaptureDef"}},{"before":"ca6988e8f03fa89acfcdad61e63eafdcdbe8e7cd","after":"70c9d98f50296f10ed88ba1dd1ce326239996569","ref":"refs/heads/mahdi/x-task-name","pushedAt":"2024-09-17T18:30:13.000Z","pushType":"push","commitsCount":1,"pusher":{"login":"mdibaiee","name":"Mahdi Dibaiee","path":"/mdibaiee","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/2807772?s=80&v=4"},"commit":{"message":"agent: refactoring SourceCapture and SourceCaptureDef","shortMessageHtmlLink":"agent: refactoring SourceCapture and SourceCaptureDef"}},{"before":"6a65c17dfe58389f0fa1b8884b8acbd6fc21d82a","after":"9d65aa59a8a74fa73a985bf21a4461459cf222ba","ref":"refs/heads/master","pushedAt":"2024-09-17T17:35:12.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"psFried","name":"Phil Fried","path":"/psFried","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/4495829?s=80&v=4"},"commit":{"message":"flowctl: use max build_id for validating local specs\n\nThe validation logic was changed in a prior commit to error if the\n`last_build_id` of a live spec is greater than the current build id.\nThis change was supposed to go along with that, but got missed. Using\nthe maximum id value ensures that we never get errors due to the build\nid being superseded.","shortMessageHtmlLink":"flowctl: use max build_id for validating local specs"}},{"before":"9e50e5f3d635f79f9042390068d00f1f1c2e40ef","after":"6a65c17dfe58389f0fa1b8884b8acbd6fc21d82a","ref":"refs/heads/master","pushedAt":"2024-09-17T17:34:40.000Z","pushType":"pr_merge","commitsCount":57,"pusher":{"login":"jshearer","name":"Joseph Shearer","path":"/jshearer","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/4368270?s=80&v=4"},"commit":{"message":"dekaf: Properly replace acks with Kafka control messages\n\nThese are messages that exist in the topics (i.e take up a particular offset location), but don't get emitted to consumers. There are two options for emitting control messages to be ignored by the consumer library: real `COMMIT` messages, and messages with an unsupported (!= 0) version. I went with the latter to avoid any potential future changes that causes the client library to do something other than skip a `COMMIT` message.","shortMessageHtmlLink":"dekaf: Properly replace acks with Kafka control messages"}},{"before":null,"after":"3621e4d42cd0377f34dc9a4333183872602cb78e","ref":"refs/heads/phil/flowctl-build-ids","pushedAt":"2024-09-17T13:52:16.000Z","pushType":"branch_creation","commitsCount":0,"pusher":{"login":"psFried","name":"Phil Fried","path":"/psFried","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/4495829?s=80&v=4"},"commit":{"message":"flowctl: use max build_id for validating local specs\n\nThe validation logic was changed in a prior commit to error if the\n`last_build_id` of a live spec is greater than the current build id.\nThis change was supposed to go along with that, but got missed. Using\nthe maximum id value ensures that we never get errors due to the build\nid being superseded.","shortMessageHtmlLink":"flowctl: use max build_id for validating local specs"}}],"hasNextPage":true,"hasPreviousPage":false,"activityType":"all","actor":null,"timePeriod":"all","sort":"DESC","perPage":30,"cursor":"djE6ks8AAAAEu0btHQA","startCursor":null,"endCursor":null}},"title":"Activity · estuary/flow"}