feat(cloud-agent): sse support for ph-code cloud runs by tatoalo · Pull Request #53754 · PostHog/posthog

tatoalo · 2026-04-08T16:16:18Z

Problem

ph_code_sse_streaming_cloud_runs.mp4

PostHog Code currently has polling-based mechanism for cloud runs. This is not good enough for release, we need SSE support.

I alreadyd did the largest plumbing work in a previous PR (and tested against Tasks UI + ph-ai sandbox mode), we need to tweak some stuff for ph-code migration. (PostHog/code#1559)

Changes

SSE event IDs: stream/ endpoint now emits id: and eventwhich enables Last-Event-ID resume and start=latest offset
TaskRun publishes state events to Redis on status/stage/output changes
Session logs pagination w/offset param and X-Has-More/X-Matching-Count response headers for cursor-free pagination
Redis stream capacity from 2,000 to 20,000 to support late-joining viewers

Publish to changelog?

No.

greptile-apps · 2026-04-08T16:21:37Z

Vulnerabilities

No security concerns identified. The stream endpoint requires task:read scope, ownership is enforced via get_object() on the existing TeamAndOrgViewSetMixin, and no new input is reflected unsanitised into the SSE output — event data comes from the Redis stream, not directly from request parameters.

Prompt To Fix All With AI

This is a comment left during a code review.
Path: products/tasks/backend/stream/redis_stream.py
Line: 198-201

Comment:
**`asyncio.run()` will raise `RuntimeError` when there is already a running event loop**

`asyncio.run()` creates a fresh event loop and raises `RuntimeError: This event loop is already running` if invoked from inside a thread that already has a running event loop. `publish_stream_state_event` is called from `update_task_run_status`, which is wrapped with `@asyncify` (i.e. `sync_to_async`). In Django's ASGI stack `sync_to_async(thread_sensitive=True)` (the default) runs the sync callable in the *main thread*, which is the same thread that owns the running event loop. That means when `asyncio.run()` is reached it will raise, silently caught by the bare `except Exception` and logged — so events are silently dropped rather than delivered.

The rest of the codebase uses `async_to_sync` (from asgiref or the project's own wrapper) for exactly this bridge:

```python
# instead of
try:
    return asyncio.run(_publish())
except Exception:
    ...

# use
from asgiref.sync import async_to_sync
try:
    return async_to_sync(_publish)()
except Exception:
    ...
```

`async_to_sync` handles the "already running loop" case correctly by dispatching the coroutine to the loop via a thread-safe queue rather than trying to create a new one.

How can I resolve this? If you propose a fix, please make it concise.

---

This is a comment left during a code review.
Path: products/tasks/backend/stream/redis_stream.py
Line: 158-168

Comment:
**`expire` called on every write doubles Redis round-trips**

The PR adds `await self._redis_client.expire(self._stream_key, self._timeout)` to `write_event`, so every event now costs two Redis operations (XADD + EXPIRE). The existing `initialize()` method already sets the expiry once when the stream is created, and `mark_complete` / `mark_error` write the sentinel that signals consumers to stop — refreshing the TTL on every intermediate event isn't needed.

If the intent is a sliding/rolling TTL (reset the clock on every write so very long-running tasks don't expire mid-run), that's a valid design, but it's worth an explicit comment and should be weighed against the doubled write cost for high-throughput streams.

How can I resolve this? If you propose a fix, please make it concise.

---

This is a comment left during a code review.
Path: products/tasks/backend/api.py
Line: 1040-1042

Comment:
**`X-Filtered-Count` now silently means "page size" — a breaking semantic change**

Before this PR, `X-Filtered-Count` was the total number of events that passed all filters (capped at `limit` because the loop broke early). Now it is explicitly `len(page)`, i.e. the size of the current slice. The new `X-Matching-Count` header provides the true total-after-filtering count.

Any existing client that relied on `X-Filtered-Count` to learn "how many events survived the filter in total" will now receive the page size instead, silently producing wrong results when `offset > 0` or when `matching_count > limit`.

Consider keeping `X-Filtered-Count` as the total filtered count (`matching_count`) for backward compatibility and renaming the new page-size header to something unambiguous like `X-Page-Count`, or documenting the breaking change explicitly.

How can I resolve this? If you propose a fix, please make it concise.

_{Reviews (1): Last reviewed commit: "feat(cloud-agent): sse support for ph-co..." | Re-trigger Greptile}

products/tasks/backend/stream/redis_stream.py

products/tasks/backend/api.py

github-actions · 2026-04-08T16:32:00Z

Size Change: 0 B

Total Size: 128 MB

ℹ️ View Unchanged

Filename	Size
`frontend/dist/368Hedgehogs`	5.26 kB
`frontend/dist/abap`	14.2 kB
`frontend/dist/Action`	23.2 kB
`frontend/dist/Actions`	1.02 kB
`frontend/dist/AdvancedActivityLogsScene`	34 kB
`frontend/dist/AgenticAuthorize`	5.25 kB
`frontend/dist/apex`	3.95 kB
`frontend/dist/ApprovalDetail`	16.2 kB
`frontend/dist/array.full.es5.js`	327 kB
`frontend/dist/array.full.js`	422 kB
`frontend/dist/array.js`	178 kB
`frontend/dist/AsyncMigrations`	13.1 kB
`frontend/dist/AuthorizationStatus`	716 B
`frontend/dist/azcli`	846 B
`frontend/dist/bat`	1.84 kB
`frontend/dist/BatchExportScene`	60.3 kB
`frontend/dist/bicep`	2.55 kB
`frontend/dist/Billing`	493 B
`frontend/dist/BillingSection`	20.8 kB
`frontend/dist/BoxPlot`	5.04 kB
`frontend/dist/browserAll-0QZMN1W2`	37.4 kB
`frontend/dist/ButtonPrimitives`	562 B
`frontend/dist/CalendarHeatMap`	4.79 kB
`frontend/dist/cameligo`	2.18 kB
`frontend/dist/changeRequestsLogic`	544 B
`frontend/dist/CLIAuthorize`	11.3 kB
`frontend/dist/CLILive`	3.97 kB
`frontend/dist/clojure`	9.64 kB
`frontend/dist/coffee`	3.59 kB
`frontend/dist/Cohort`	23.2 kB
`frontend/dist/CohortCalculationHistory`	6.22 kB
`frontend/dist/Cohorts`	9.39 kB
`frontend/dist/ConfirmOrganization`	4.48 kB
`frontend/dist/conversations.js`	65.8 kB
`frontend/dist/Coupons`	720 B
`frontend/dist/cpp`	5.3 kB
`frontend/dist/Create`	655 B
`frontend/dist/crisp-chat-integration.js`	1.88 kB
`frontend/dist/csharp`	4.52 kB
`frontend/dist/csp`	1.42 kB
`frontend/dist/css`	4.51 kB
`frontend/dist/cssMode`	4.15 kB
`frontend/dist/CustomCssScene`	3.55 kB
`frontend/dist/CustomerAnalyticsConfigurationScene`	1.99 kB
`frontend/dist/CustomerAnalyticsScene`	26.2 kB
`frontend/dist/CustomerJourneyBuilderScene`	1.69 kB
`frontend/dist/CustomerJourneyTemplatesScene`	7.39 kB
`frontend/dist/customizations.full.js`	17.9 kB
`frontend/dist/CyclotronJobInputAssignee`	1.32 kB
`frontend/dist/CyclotronJobInputTicketTags`	711 B
`frontend/dist/cypher`	3.38 kB
`frontend/dist/dart`	4.25 kB
`frontend/dist/Dashboard`	1.04 kB
`frontend/dist/Dashboards`	19.9 kB
`frontend/dist/DataManagementScene`	646 B
`frontend/dist/DataPipelinesNewScene`	2.28 kB
`frontend/dist/DataWarehouseScene`	1.19 kB
`frontend/dist/DataWarehouseSourceScene`	634 B
`frontend/dist/Deactivated`	1.13 kB
`frontend/dist/dead-clicks-autocapture.js`	13.1 kB
`frontend/dist/DeadLetterQueue`	5.38 kB
`frontend/dist/DebugScene`	20 kB
`frontend/dist/decompressionWorker`	2.85 kB
`frontend/dist/decompressionWorker.js`	2.85 kB
`frontend/dist/DefinitionEdit`	7.11 kB
`frontend/dist/DefinitionView`	22.7 kB
`frontend/dist/DestinationsScene`	2.67 kB
`frontend/dist/dist`	575 B
`frontend/dist/dockerfile`	1.87 kB
`frontend/dist/EarlyAccessFeature`	719 B
`frontend/dist/EarlyAccessFeatures`	2.84 kB
`frontend/dist/ecl`	5.33 kB
`frontend/dist/EditorScene`	896 B
`frontend/dist/elixir`	10.3 kB
`frontend/dist/elk.bundled`	1.44 MB
`frontend/dist/EmailMFAVerify`	2.98 kB
`frontend/dist/EndpointScene`	37.5 kB
`frontend/dist/EndpointsScene`	22.1 kB
`frontend/dist/ErrorTrackingConfigurationScene`	2.2 kB
`frontend/dist/ErrorTrackingIssueFingerprintsScene`	6.98 kB
`frontend/dist/ErrorTrackingIssueScene`	81.9 kB
`frontend/dist/ErrorTrackingScene`	12.9 kB
`frontend/dist/EvaluationTemplates`	575 B
`frontend/dist/EventsScene`	2.46 kB
`frontend/dist/exception-autocapture.js`	11.8 kB
`frontend/dist/Experiment`	208 kB
`frontend/dist/Experiments`	17.1 kB
`frontend/dist/exporter`	20.8 MB
`frontend/dist/exporter.js`	20.8 MB
`frontend/dist/ExportsScene`	3.86 kB
`frontend/dist/FeatureFlag`	128 kB
`frontend/dist/FeatureFlags`	572 B
`frontend/dist/FeatureFlagTemplatesScene`	7.03 kB
`frontend/dist/FlappyHog`	5.78 kB
`frontend/dist/flow9`	1.8 kB
`frontend/dist/freemarker2`	16.7 kB
`frontend/dist/fsharp`	2.98 kB
`frontend/dist/go`	2.65 kB
`frontend/dist/graphql`	2.26 kB
`frontend/dist/Group`	14.3 kB
`frontend/dist/Groups`	3.93 kB
`frontend/dist/GroupsNew`	7.34 kB
`frontend/dist/handlebars`	7.34 kB
`frontend/dist/hcl`	3.59 kB
`frontend/dist/HealthCategoryDetailScene`	7.23 kB
`frontend/dist/HealthScene`	10.3 kB
`frontend/dist/HeatmapNewScene`	4.16 kB
`frontend/dist/HeatmapRecordingScene`	3.92 kB
`frontend/dist/HeatmapScene`	6.03 kB
`frontend/dist/HeatmapsScene`	3.88 kB
`frontend/dist/hls`	394 kB
`frontend/dist/HogFunctionScene`	58.3 kB
`frontend/dist/HogRepl`	7.37 kB
`frontend/dist/html`	5.58 kB
`frontend/dist/htmlMode`	4.62 kB
`frontend/dist/image-blob-reduce.esm`	49.4 kB
`frontend/dist/InboxScene`	59.1 kB
`frontend/dist/index`	306 kB
`frontend/dist/index.js`	306 kB
`frontend/dist/ini`	1.1 kB
`frontend/dist/InsightOptions`	5.41 kB
`frontend/dist/InsightScene`	28.8 kB
`frontend/dist/IntegrationsRedirect`	733 B
`frontend/dist/intercom-integration.js`	1.93 kB
`frontend/dist/InviteSignup`	14.4 kB
`frontend/dist/java`	3.22 kB
`frontend/dist/javascript`	985 B
`frontend/dist/jsonMode`	13.9 kB
`frontend/dist/julia`	7.22 kB
`frontend/dist/kotlin`	3.4 kB
`frontend/dist/lazy`	150 kB
`frontend/dist/LegacyPluginScene`	26.6 kB
`frontend/dist/LemonTextAreaMarkdown`	502 B
`frontend/dist/less`	3.9 kB
`frontend/dist/lexon`	2.44 kB
`frontend/dist/lib`	2.22 kB
`frontend/dist/Link`	468 B
`frontend/dist/LinkScene`	24.8 kB
`frontend/dist/LinksScene`	4.19 kB
`frontend/dist/liquid`	4.53 kB
`frontend/dist/LiveDebugger`	19.1 kB
`frontend/dist/LiveEventsTable`	2.98 kB
`frontend/dist/LLMAnalyticsClusterScene`	15.7 kB
`frontend/dist/LLMAnalyticsClustersScene`	43.1 kB
`frontend/dist/LLMAnalyticsDatasetScene`	19.7 kB
`frontend/dist/LLMAnalyticsDatasetsScene`	3.28 kB
`frontend/dist/LLMAnalyticsEvaluation`	40.7 kB
`frontend/dist/LLMAnalyticsEvaluationsScene`	29.5 kB
`frontend/dist/LLMAnalyticsPlaygroundScene`	36.3 kB
`frontend/dist/LLMAnalyticsScene`	116 kB
`frontend/dist/LLMAnalyticsSessionScene`	13.4 kB
`frontend/dist/LLMAnalyticsTraceScene`	127 kB
`frontend/dist/LLMAnalyticsUsers`	526 B
`frontend/dist/LLMASessionFeedbackDisplay`	4.83 kB
`frontend/dist/LLMPromptScene`	20.6 kB
`frontend/dist/LLMPromptsScene`	4.21 kB
`frontend/dist/Login`	8.57 kB
`frontend/dist/Login2FA`	4.2 kB
`frontend/dist/logs.js`	38.5 kB
`frontend/dist/LogsScene`	11.3 kB
`frontend/dist/lua`	2.11 kB
`frontend/dist/m3`	2.81 kB
`frontend/dist/main`	819 kB
`frontend/dist/ManagedMigration`	14 kB
`frontend/dist/markdown`	3.79 kB
`frontend/dist/MarketingAnalyticsScene`	39.7 kB
`frontend/dist/MaterializedColumns`	10.2 kB
`frontend/dist/Max`	835 B
`frontend/dist/mdx`	5.39 kB
`frontend/dist/MessageTemplate`	16.3 kB
`frontend/dist/MetricsScene`	828 B
`frontend/dist/mips`	2.58 kB
`frontend/dist/ModelsScene`	13.6 kB
`frontend/dist/MonacoDiffEditor`	403 B
`frontend/dist/monacoEditorWorker`	288 kB
`frontend/dist/monacoEditorWorker.js`	288 kB
`frontend/dist/monacoJsonWorker`	419 kB
`frontend/dist/monacoJsonWorker.js`	419 kB
`frontend/dist/monacoTsWorker`	7.02 MB
`frontend/dist/monacoTsWorker.js`	7.02 MB
`frontend/dist/MoveToPostHogCloud`	4.46 kB
`frontend/dist/msdax`	4.91 kB
`frontend/dist/mysql`	11.3 kB
`frontend/dist/NavTabChat`	4.68 kB
`frontend/dist/NewSourceWizard`	724 B
`frontend/dist/NewTabScene`	681 B
`frontend/dist/NodeDetailScene`	16.3 kB
`frontend/dist/NotebookCanvasScene`	3.09 kB
`frontend/dist/NotebookPanel`	5.11 kB
`frontend/dist/NotebookScene`	8.11 kB
`frontend/dist/NotebooksScene`	7.58 kB
`frontend/dist/OAuthAuthorize`	573 B
`frontend/dist/objective-c`	2.41 kB
`frontend/dist/Onboarding`	683 kB
`frontend/dist/OnboardingCouponRedemption`	1.2 kB
`frontend/dist/pascal`	2.99 kB
`frontend/dist/pascaligo`	2 kB
`frontend/dist/passkeyLogic`	484 B
`frontend/dist/PasswordReset`	4.32 kB
`frontend/dist/PasswordResetComplete`	2.94 kB
`frontend/dist/perl`	8.25 kB
`frontend/dist/PersonScene`	16 kB
`frontend/dist/PersonsScene`	4.73 kB
`frontend/dist/pgsql`	13.5 kB
`frontend/dist/php`	8.02 kB
`frontend/dist/PipelineStatusScene`	6.22 kB
`frontend/dist/pla`	1.67 kB
`frontend/dist/posthog`	136 kB
`frontend/dist/postiats`	7.86 kB
`frontend/dist/powerquery`	16.9 kB
`frontend/dist/powershell`	3.27 kB
`frontend/dist/PreflightCheck`	5.53 kB
`frontend/dist/product-tours.js`	115 kB
`frontend/dist/ProductTour`	273 kB
`frontend/dist/ProductTours`	4.68 kB
`frontend/dist/ProjectHomepage`	24.7 kB
`frontend/dist/protobuf`	9.05 kB
`frontend/dist/pug`	4.82 kB
`frontend/dist/python`	4.76 kB
`frontend/dist/qsharp`	3.19 kB
`frontend/dist/r`	3.12 kB
`frontend/dist/razor`	9.35 kB
`frontend/dist/recorder-v2.js`	111 kB
`frontend/dist/recorder.js`	111 kB
`frontend/dist/redis`	3.55 kB
`frontend/dist/redshift`	11.8 kB
`frontend/dist/RegionMap`	29.4 kB
`frontend/dist/render-query`	20.5 MB
`frontend/dist/render-query.js`	20.5 MB
`frontend/dist/ResourceTransfer`	9.17 kB
`frontend/dist/restructuredtext`	3.9 kB
`frontend/dist/RevenueAnalyticsScene`	25.6 kB
`frontend/dist/ruby`	8.5 kB
`frontend/dist/rust`	4.16 kB
`frontend/dist/SavedInsights`	664 B
`frontend/dist/sb`	1.82 kB
`frontend/dist/scala`	7.32 kB
`frontend/dist/scheme`	1.76 kB
`frontend/dist/scss`	6.41 kB
`frontend/dist/SdkDoctorScene`	9.4 kB
`frontend/dist/SessionAttributionExplorerScene`	6.62 kB
`frontend/dist/SessionGroupSummariesTable`	4.62 kB
`frontend/dist/SessionGroupSummaryScene`	17 kB
`frontend/dist/SessionProfileScene`	15.8 kB
`frontend/dist/SessionRecordingDetail`	1.73 kB
`frontend/dist/SessionRecordingFilePlaybackScene`	4.46 kB
`frontend/dist/SessionRecordings`	742 B
`frontend/dist/SessionRecordingsKiosk`	8.84 kB
`frontend/dist/SessionRecordingsPlaylistScene`	4.14 kB
`frontend/dist/SessionRecordingsSettingsScene`	1.9 kB
`frontend/dist/SessionsScene`	3.86 kB
`frontend/dist/SettingsScene`	2.98 kB
`frontend/dist/SharedMetric`	4.83 kB
`frontend/dist/SharedMetrics`	549 B
`frontend/dist/shell`	3.07 kB
`frontend/dist/SignupContainer`	24.5 kB
`frontend/dist/Site`	1.18 kB
`frontend/dist/solidity`	18.6 kB
`frontend/dist/sophia`	2.76 kB
`frontend/dist/SourcesScene`	5.96 kB
`frontend/dist/sourceWizardLogic`	662 B
`frontend/dist/sparql`	2.55 kB
`frontend/dist/sql`	10.3 kB
`frontend/dist/SqlVariableEditScene`	7.24 kB
`frontend/dist/st`	7.4 kB
`frontend/dist/StartupProgram`	21.2 kB
`frontend/dist/SupportSettingsScene`	1.16 kB
`frontend/dist/SupportTicketScene`	23 kB
`frontend/dist/SupportTicketsScene`	733 B
`frontend/dist/Survey`	746 B
`frontend/dist/SurveyFormBuilder`	1.54 kB
`frontend/dist/Surveys`	18.2 kB
`frontend/dist/surveys.js`	89.8 kB
`frontend/dist/SurveyWizard`	66.8 kB
`frontend/dist/swift`	5.26 kB
`frontend/dist/SystemStatus`	16.8 kB
`frontend/dist/systemverilog`	7.61 kB
`frontend/dist/TaskDetailScene`	20.1 kB
`frontend/dist/TaskTracker`	13.2 kB
`frontend/dist/tcl`	3.57 kB
`frontend/dist/TextCardMarkdownEditor`	11 kB
`frontend/dist/toolbar`	10.2 MB
`frontend/dist/toolbar.js`	10.2 MB
`frontend/dist/ToolbarLaunch`	2.52 kB
`frontend/dist/tracing-headers.js`	1.74 kB
`frontend/dist/TracingScene`	29.3 kB
`frontend/dist/TransformationsScene`	1.91 kB
`frontend/dist/tsMode`	24 kB
`frontend/dist/twig`	5.97 kB
`frontend/dist/TwoFactorReset`	3.98 kB
`frontend/dist/typescript`	240 B
`frontend/dist/typespec`	2.82 kB
`frontend/dist/Unsubscribe`	1.62 kB
`frontend/dist/UserInterview`	4.53 kB
`frontend/dist/UserInterviews`	2.01 kB
`frontend/dist/vb`	5.79 kB
`frontend/dist/VercelConnect`	4.95 kB
`frontend/dist/VercelLinkError`	1.91 kB
`frontend/dist/VerifyEmail`	4.48 kB
`frontend/dist/vimMode`	211 kB
`frontend/dist/VisualReviewRunScene`	18.6 kB
`frontend/dist/VisualReviewRunsScene`	6.16 kB
`frontend/dist/VisualReviewSettingsScene`	10.6 kB
`frontend/dist/web-vitals.js`	6.39 kB
`frontend/dist/WebAnalyticsScene`	5.77 kB
`frontend/dist/WebGLRenderer-DYjOwNoG`	60.3 kB
`frontend/dist/WebGPURenderer-B_wkl_Ja`	36.3 kB
`frontend/dist/WebScriptsScene`	2.54 kB
`frontend/dist/webworkerAll-puPV1rBA`	324 B
`frontend/dist/wgsl`	7.34 kB
`frontend/dist/Wizard`	4.45 kB
`frontend/dist/WorkflowScene`	103 kB
`frontend/dist/WorkflowsScene`	46.9 kB
`frontend/dist/WorldMap`	4.73 kB
`frontend/dist/xml`	2.98 kB
`frontend/dist/yaml`	4.6 kB

_{compressed-size-action}

greptile-apps · 2026-04-09T08:14:29Z

Vulnerabilities

No security concerns identified. The SSE endpoint reuses existing required_scopes=["task:read"] auth; Redis stream IDs are opaque monotonic timestamps with no user-controlled values; JSON serialisation is handled by stdlib json.dumps; the offset parameter is validated by the serializer (min_value=0, max_value bounded).

Prompt To Fix All With AI

This is a comment left during a code review.
Path: products/tasks/backend/tests/test_api.py
Line: 1603-1604

Comment:
**`all()` vacuous truth masks empty-events failure**

`all(pred for event in events)` returns `True` when `events` is empty, so if a timing hiccup causes the stream to yield nothing, this assertion silently passes. The subsequent `events[-1]` then raises an opaque `IndexError` instead of a clear assertion failure. Add an explicit length check before the `all()`:

```suggestion
        self.assertGreaterEqual(len(events), 1, "Expected at least one SSE event but got none")
        self.assertTrue(all(event["data"]["notification"]["method"] == "_posthog/console" for event in events), events)
```

How can I resolve this? If you propose a fix, please make it concise.

---

This is a comment left during a code review.
Path: products/tasks/backend/tests/test_api.py
Line: 1575-1605

Comment:
**Timing-sensitive test can be flaky in slow CI**

`publish_future_events` sleeps 50 ms before publishing and marking the stream complete. The stream reader polls with `block_ms=100`, so in theory the event is always captured — but the 50 ms margin is tight when the test runner is under load. If the stream's first `xread` call doesn't block at all (e.g. already expired by the time the test starts), the reader can miss the window.

Consider using a `threading.Event` / `queue.Queue` handshake instead of a fixed sleep, or at minimum increase the sleep to 200 ms to give more headroom.

How can I resolve this? If you propose a fix, please make it concise.

---

This is a comment left during a code review.
Path: products/tasks/backend/api.py
Line: 1015-1042

Comment:
**Full scan for `matching_count` removes early-exit optimisation**

Previously the filter loop broke at `len(filtered) >= limit`, so at most `limit` entries were ever iterated after the first `limit` matches. Now the loop always runs over every entry to compute `matching_count`, which is needed for proper pagination. For the typical task-run this is fine, but S3 log files are unbounded — a long-running run with hundreds of thousands of entries will pay O(N) filtering cost on every page request even when `limit` is small.

Consider documenting the known trade-off with a comment so future readers don't re-add the early break by accident.

How can I resolve this? If you propose a fix, please make it concise.

_{Reviews (2): Last reviewed commit: "chore: update OpenAPI generated types" | Re-trigger Greptile}

greptile-apps · 2026-04-09T08:14:32Z

Tip:

Greploop — Automatically fix all review issues by running /greploops in Claude Code. It iterates: fix, push, re-review, repeat until 5/5 confidence.

Use the Greptile plugin for Claude Code to query reviews, search comments, and manage custom context directly from your terminal.

chore: cleaner chore: cleaner

tatoalo self-assigned this Apr 8, 2026

tatoalo mentioned this pull request Apr 8, 2026

feat(cloud): cloud task SSE streaming PostHog/code#1559

Open

tatoalo marked this pull request as draft April 8, 2026 16:17

greptile-apps bot reviewed Apr 8, 2026

View reviewed changes

products/tasks/backend/stream/redis_stream.py Show resolved Hide resolved

products/tasks/backend/stream/redis_stream.py Show resolved Hide resolved

products/tasks/backend/api.py Show resolved Hide resolved

tatoalo force-pushed the feat/cloud-agent/sse-support-ph-code branch 2 times, most recently from dfb63c2 to 9a5bd05 Compare April 9, 2026 08:02

tatoalo marked this pull request as ready for review April 9, 2026 08:02

tatoalo requested a review from a team April 9, 2026 10:03

tatoalo force-pushed the feat/cloud-agent/sse-support-ph-code branch from 9a5bd05 to 8ed0f52 Compare April 9, 2026 13:20

tatoalo and others added 2 commits April 9, 2026 15:35

feat(cloud-agent): sse support for ph-code cloud runs

4ba2133

chore: cleaner chore: cleaner

chore: update OpenAPI generated types

695aaf5

tatoalo force-pushed the feat/cloud-agent/sse-support-ph-code branch from 8ed0f52 to 695aaf5 Compare April 9, 2026 14:45

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

feat(cloud-agent): sse support for ph-code cloud runs#53754

feat(cloud-agent): sse support for ph-code cloud runs#53754
tatoalo wants to merge 2 commits intomasterfrom
feat/cloud-agent/sse-support-ph-code

tatoalo commented Apr 8, 2026 •

edited

Loading

Uh oh!

greptile-apps bot commented Apr 8, 2026

Vulnerabilities

Uh oh!

Uh oh!

Uh oh!

Uh oh!

github-actions bot commented Apr 8, 2026 •

edited

Loading

Uh oh!

greptile-apps bot commented Apr 9, 2026

Vulnerabilities

Uh oh!

greptile-apps bot commented Apr 9, 2026

Uh oh!

Reviewers

Assignees

Labels

Projects

Milestone

Development

Uh oh!

1 participant

Conversation

tatoalo commented Apr 8, 2026 • edited Loading Uh oh! There was an error while loading. Please reload this page.

Uh oh!

Problem

Changes

Publish to changelog?

Uh oh!

greptile-apps bot commented Apr 8, 2026

Vulnerabilities

Uh oh!

Uh oh!

Uh oh!

Uh oh!

github-actions bot commented Apr 8, 2026 • edited Loading Uh oh! There was an error while loading. Please reload this page.

Uh oh!

Uh oh!

greptile-apps bot commented Apr 9, 2026

Vulnerabilities

Uh oh!

greptile-apps bot commented Apr 9, 2026

Uh oh!

Reviewers

Assignees

Labels

Projects

Milestone

Development

Uh oh!

1 participant

tatoalo commented Apr 8, 2026 •

edited

Loading

github-actions bot commented Apr 8, 2026 •

edited

Loading