Skip to content
Open
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
23 changes: 23 additions & 0 deletions plugins/acp/acp_plugin_gamesdk/acp_plugin.py
Original file line number Diff line number Diff line change
Expand Up @@ -6,6 +6,7 @@
from dataclasses import dataclass, asdict
from datetime import datetime
import traceback
import time

import socketio
import socketio.client
Expand Down Expand Up @@ -626,3 +627,25 @@ def _deliver_job_executable(self, jobId: int, deliverableType: str, deliverable:
except Exception as e:
print(traceback.format_exc())
return FunctionResultStatus.FAILED, f"System error while delivering items - try again after a short delay. {str(e)}", {}

@property
def wait(self) -> Function:

wait_duration_arg = Argument(
name="waitDuration",
type="integer",
description="The duration to wait in seconds (minimum 30 seconds)",
)

return Function(
fn_name="wait",
fn_description="Waits for a specified amount of time",
args=[wait_duration_arg],
executable=self._wait_executable
)

def _wait_executable(self, waitDuration: int) -> Tuple[FunctionResultStatus, str, dict]:
if waitDuration < 30:
waitDuration = 30
time.sleep(waitDuration)
return FunctionResultStatus.DONE, f"Waited for {waitDuration} seconds", {}