Update core.py

Author: justinmerrell

runpod/serverless/core.py

@@ -207,18 +207,21 @@ async def run(config: Dict[str, Any]) -> None:
     while True:
         jobs = hook.get_jobs(max_concurrency, max_jobs)
 
-        if len(jobs) == 0:
+        if len(jobs) == 0 or jobs is None:
             continue
 
         for job in jobs:
-            asyncio.create_task(_process_job(handler, job))
+            asyncio.create_task(_process_job(handler, job), name=job['id'])
             await asyncio.sleep(0)
 
         await asyncio.sleep(0)
 
 
 def main(config: Dict[str, Any]) -> None:
     """Run the worker in an asyncio event loop."""
+    if config.get('handler') is None:
+        raise ValueError("config must contain a handler function")
+
     try:
         work_loop = asyncio.new_event_loop()
         asyncio.ensure_future(run(config), loop=work_loop)