Skip to content

Commit 88266ed

Browse files
fix: redis port 6397 -> 6379
1 parent e016abc commit 88266ed

3 files changed

Lines changed: 5 additions & 5 deletions

File tree

README.md

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -17,7 +17,7 @@ from litestar import Litestar
1717

1818
from litestar_saq import QueueConfig, SAQConfig, SAQPlugin
1919

20-
saq = SAQPlugin(config=SAQConfig(dsn="redis://localhost:6397/0", queue_configs=[QueueConfig(name="samples")]))
20+
saq = SAQPlugin(config=SAQConfig(dsn="redis://localhost:6379/0", queue_configs=[QueueConfig(name="samples")]))
2121
app = Litestar(plugins=[saq])
2222

2323

@@ -29,7 +29,7 @@ You can start a background worker with the following command now:
2929
litestar --app-dir=examples/ --app basic:app workers run
3030
Using Litestar app from env: 'basic:app'
3131
Starting SAQ Workers ──────────────────────────────────────────────────────────────────
32-
INFO - 2023-10-04 17:39:03,255 - saq - worker - Worker starting: Queue<redis=Redis<ConnectionPool<Connection<host=localhost,port=6397,db=0>>>, name='samples'>
32+
INFO - 2023-10-04 17:39:03,255 - saq - worker - Worker starting: Queue<redis=Redis<ConnectionPool<Connection<host=localhost,port=6379,db=0>>>, name='samples'>
3333
INFO - 2023-10-04 17:39:06,545 - saq - worker - Worker shutting down
3434
```
3535

@@ -39,7 +39,7 @@ You can also start the process for only specific queues. This is helpful if you
3939
litestar --app-dir=examples/ --app basic:app workers run --queues sample
4040
Using Litestar app from env: 'basic:app'
4141
Starting SAQ Workers ──────────────────────────────────────────────────────────────────
42-
INFO - 2023-10-04 17:39:03,255 - saq - worker - Worker starting: Queue<redis=Redis<ConnectionPool<Connection<host=localhost,port=6397,db=0>>>, name='samples'>
42+
INFO - 2023-10-04 17:39:03,255 - saq - worker - Worker starting: Queue<redis=Redis<ConnectionPool<Connection<host=localhost,port=6379,db=0>>>, name='samples'>
4343
INFO - 2023-10-04 17:39:06,545 - saq - worker - Worker shutting down
4444
```
4545

examples/basic.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -27,7 +27,7 @@ async def samples_queue_info(self, task_queues: TaskQueues) -> QueueInfo:
2727
use_server_lifespan=True,
2828
queue_configs=[
2929
QueueConfig(
30-
dsn="redis://localhost:6397/0",
30+
dsn="redis://localhost:6379/0",
3131
name="samples",
3232
tasks=[tasks.background_worker_task, tasks.system_task, tasks.system_upkeep],
3333
scheduled_tasks=[CronJob(function=tasks.system_upkeep, cron="* * * * *", timeout=600, ttl=2000)],

tests/test_cli/__init__.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -55,7 +55,7 @@ async def samples_queue_info(self, task_queues: TaskQueues) -> QueueInfo:
5555
use_server_lifespan=True,
5656
queue_configs=[
5757
QueueConfig(
58-
dsn="redis://localhost:6397/0",
58+
dsn="redis://localhost:6379/0",
5959
name="samples",
6060
tasks=[tasks.background_worker_task, tasks.system_task, tasks.system_upkeep],
6161
scheduled_tasks=[CronJob(function=tasks.system_upkeep, cron="* * * * *", timeout=600, ttl=2000)],

0 commit comments

Comments
 (0)