Skip to content

feat: add worker_beat container for Celery Beat scheduling#107

Open
WinterYukky wants to merge 2 commits intoaws-samples:mainfrom
WinterYukky:feature/add-worker-beat-service-1772154205
Open

feat: add worker_beat container for Celery Beat scheduling#107
WinterYukky wants to merge 2 commits intoaws-samples:mainfrom
WinterYukky:feature/add-worker-beat-service-1772154205

Conversation

@WinterYukky
Copy link
Copy Markdown
Contributor

@WinterYukky WinterYukky commented Feb 27, 2026

Issue #86, if available:

Closes #86

Description of changes:

Summary

Adds a WorkerBeat container (Celery Beat) to the ECS task definition, enabling the Schedule Trigger feature (Dify v1.13.0+) and plugin auto-upgrade.

Closes #86

Changes

  • lib/constructs/dify-services/api.ts: Added WorkerBeat container with MODE: beat
  • lib/environment-props.ts: Added worker_beat to DifyContainerTypes
  • Snapshot tests updated

Verified

  • ✅ Deployed and confirmed all containers are running (no crashes)
  • ✅ Schedule Trigger functionality works end-to-en

By submitting this pull request, I confirm that you can use, modify, copy, and redistribute this contribution, under the terms of your choice.

@WinterYukky WinterYukky changed the title feat: add worker_beat container for Celery Beat scheduling [WIP] feat: add worker_beat container for Celery Beat scheduling Feb 27, 2026
Add a WorkerBeat sidecar container to the Fargate task definition to
support Dify's Schedule Trigger feature (added in v1.13.0) and plugin
auto-upgrade functionality.

The worker_beat container runs Celery Beat (MODE=beat) which schedules
periodic tasks such as schedule_poller, schedule_executor, and
triggered_workflow_dispatcher queues that are consumed by the worker.

Changes:
- Add 'worker_beat' to DifyContainerTypes for additionalEnvironmentVariables support
- Add WorkerBeat container with DB and Redis connectivity
- Update snapshot tests

Closes aws-samples#86
@remote-swe remote-swe bot force-pushed the feature/add-worker-beat-service-1772154205 branch from aa32467 to b1ebfe5 Compare February 27, 2026 07:25
@WinterYukky WinterYukky changed the title [WIP] feat: add worker_beat container for Celery Beat scheduling feat: add worker_beat container for Celery Beat scheduling Feb 27, 2026
@yhiroaky
Copy link
Copy Markdown
Contributor

yhiroaky commented Mar 2, 2026

コントリビューションありがとうございます。

Dify の Dockerイメージに v1.13.0 が必要になるので、以下の順序を考えております。

  1. Feat/aws cdk version up #108 の対応 Bump minimatch and aws-cdk-lib #106 の対応
  2. v1.13.0 へのタグアップグレード not includes Worker_beat(手元の環境で問題ないこと確認済み)Update Dify version to v1.13.0 and Plugin Daemon to v0.5.3-local #110
  3. feat: add worker_beat container for Celery Beat scheduling #107 とのコンフリクトの有無と動作検証ののちマージ

@yhiroaky
Copy link
Copy Markdown
Contributor

yhiroaky commented Mar 3, 2026

main ブランチを Dify v1.13.0, Daemon v0.5.3-local にあげました。
すみませんが、PRのコンフリクトの解消お願いしてもよろしいでしょうか?

--

I've updated the main branch to Dify v1.13.0 and Daemon v0.5.3-local.
I apologize for the inconvenience, but could you please resolve the PR conflicts?

@WinterYukky
Copy link
Copy Markdown
Contributor Author

Thank you for your review! @yhiroaky
I fixed it now! Could you recheck it?

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

Add worker_beat service

2 participants