We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent e23cc2e commit 380820eCopy full SHA for 380820e
packages/celery-library/src/celery_library/task_manager.py
@@ -45,7 +45,7 @@ async def send_task(
45
name: TaskName,
46
context: TaskContext,
47
*,
48
- is_ephemeral: bool = False,
+ ephemeral: bool = True,
49
queue: TaskQueue = TASK_QUEUE_DEFAULT,
50
**params,
51
) -> TaskUUID:
@@ -65,14 +65,14 @@ async def send_task(
65
66
expiry = (
67
self._celery_settings.CELERY_EPHEMERAL_RESULT_EXPIRES
68
- if is_ephemeral
+ if ephemeral
69
else self._celery_settings.CELERY_RESULT_EXPIRES
70
)
71
await self._task_info_store.create_task(
72
task_id,
73
TaskMetadata(
74
name=name,
75
- ephemeral=is_ephemeral,
+ ephemeral=ephemeral,
76
queue=queue,
77
),
78
expiry=expiry,
0 commit comments