Update core.py

Author: justinmerrell

runpod/serverless/core.py

@@ -170,7 +170,7 @@ def finish_stream(self, job_id: str) -> bool:
 
 
 # -------------------------------- Process Job ------------------------------- #
-def _process_job(handler: Callable, job: Dict[str, Any]) -> Dict[str, Any]:
+async def _process_job(handler: Callable, job: Dict[str, Any]) -> Dict[str, Any]:
     """ Process a single job. """
     hook = Hook()