Skip to content

Commit f14d87b

Browse files
committed
fix server crashing
WHAT THE FUCK NO ONE TOLD ME EXCLUSIVE CANCELS EVERYTHING ELSE WHAT THE FUCK IS THIS CODE WILL
1 parent df0ecfd commit f14d87b

2 files changed

Lines changed: 6 additions & 6 deletions

File tree

src/rovr/app.py

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -391,7 +391,7 @@ def post_mount(self) -> None:
391391

392392
start_server(self)
393393

394-
@work
394+
@work(group="crasher")
395395
async def _force_crash(self) -> None:
396396
await asyncio.sleep(self._force_crash_in)
397397
1 / 0
@@ -471,7 +471,7 @@ def on_shell_exec_response(
471471
if response.run_type == "background":
472472
self.shell_thread(proc, "Shell Exec")
473473

474-
@work(thread=True)
474+
@work(thread=True, group="shell")
475475
def shell_thread(self, proc: Popen, title: str = "") -> None:
476476
self._background_processes.add(proc)
477477
try:
@@ -520,7 +520,7 @@ def _set_mouse_over(
520520
return
521521
super()._set_mouse_over(widget, hover_widget)
522522

523-
@work
523+
@work(group="quitter")
524524
async def action_quit(self, can_cd: bool = True) -> None:
525525
from rovr.screens import YesOrNo
526526

@@ -645,7 +645,7 @@ def cd(
645645
# down, so we can just ignore this error
646646
return
647647

648-
@work(thread=True)
648+
@work(thread=True, group="bg")
649649
def watch_for_changes_and_update(self) -> None:
650650
cwd = getcwd()
651651
file_list: FileList = self.query_one(FileList)
@@ -841,7 +841,7 @@ def watch_for_changes_and_update(self) -> None:
841841
elif not path.exists(custom_style_path):
842842
style_available = False
843843

844-
@work(exclusive=True)
844+
@work(exclusive=True, group="resizer")
845845
async def on_resize(self, event: events.Resize) -> None:
846846
if (
847847
event.size.height < MAX_HEIGHT or event.size.width < MAX_WIDTH

src/rovr/functions/ipc_receiver.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -453,7 +453,7 @@ async def wrapper(
453453
await writer.wait_closed()
454454

455455

456-
@work
456+
@work(group="server")
457457
async def start_server(self: Application) -> None:
458458
from rovr.functions.ipc_instances import publish_instance, unpublish_instance
459459

0 commit comments

Comments
 (0)