Skip to content

Commit ff08147

Browse files
chore: recover slack (eigent-ai#1153)
Co-authored-by: Wendong-Fan <133094783+Wendong-Fan@users.noreply.github.com> Co-authored-by: Wendong-Fan <w3ndong.fan@gmail.com>
1 parent 96a6209 commit ff08147

5 files changed

Lines changed: 915 additions & 808 deletions

File tree

backend/app/component/environment.py

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -77,11 +77,11 @@ def sanitize_env_path(env_path: str | None) -> str | None:
7777
)
7878
return None
7979

80-
# Enforce .env file extension
81-
if not resolved_path.name.endswith(".env"):
80+
name = resolved_path.name
81+
if not (name.endswith(".env") or name.startswith(".env.")):
8282
logger.warning(
8383
f"Security: Rejected env_path with invalid extension. "
84-
f"Path: {env_path}, must end with .env"
84+
f"Path: {env_path}, must be .env or .env.*"
8585
)
8686
return None
8787

backend/app/utils/workforce.py

Lines changed: 7 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -809,14 +809,17 @@ async def _handle_failed_task(self, task: Task) -> bool:
809809

810810
if metrics_callbacks:
811811
error_msg = error_message or str(task.result or "Unknown error")
812+
# Pass all values during construction since TaskFailedEvent is frozen
813+
worker_id = (
814+
task.assigned_worker_id
815+
if hasattr(task, "assigned_worker_id")
816+
else None
817+
)
812818
event = TaskFailedEvent(
813819
task_id=task.id,
814820
error_message=error_msg,
821+
worker_id=worker_id,
815822
)
816-
# Add failure details if available
817-
if hasattr(task, "assigned_worker_id"):
818-
event.worker_id = task.assigned_worker_id
819-
event.failure_count = task.failure_count
820823
metrics_callbacks[0].log_task_failed(event)
821824

822825
return result

0 commit comments

Comments
 (0)