Skip to content
Merged
Show file tree
Hide file tree
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
2 changes: 1 addition & 1 deletion docs/serverless/worker.md
Original file line number Diff line number Diff line change
Expand Up @@ -2,7 +2,7 @@

Both Runpod official endpoints as well as custom built endpoints function by means of a worker that fetches available jobs, passes them into a handler and then returns the output.

A worker entry point is a python file containing the command `runpod.serverless.start(config)`. An minimal worker file is shown below:
A worker entry point is a python file containing the command `runpod.serverless.start(config)`. A minimal worker file is shown below:

```python
import runpod
Expand Down
2 changes: 1 addition & 1 deletion docs/serverless/worker_realtime.md
Original file line number Diff line number Diff line change
Expand Up @@ -10,4 +10,4 @@ A worker will be launched as a realtime worker if the `RUNPOD_REALTIME_PORT` env

### Concurrent Requests

By default the realtime worker will only process one request at a time. This can be changed by setting the `RUNPOD_REALTIME_CONCURRENCY` environment variable. This variable should be set to the number of concurrent requests that should be processed.
By default, the realtime worker will only process one request at a time. This can be changed by setting the `RUNPOD_REALTIME_CONCURRENCY` environment variable. This variable should be set to the number of concurrent requests that should be processed.
2 changes: 1 addition & 1 deletion runpod/endpoint/asyncio/asyncio_runner.py
Original file line number Diff line number Diff line change
Expand Up @@ -36,7 +36,7 @@ def __init__(self, endpoint_id: str, job_id: str, session: ClientSession, header
self.job_output = None

async def _fetch_job(self, source: str = "status") -> Dict[str, Any]:
"""Returns the raw json of the status, reaises an exception if invalid.
"""Returns the raw json of the status, raises an exception if invalid.

Args:
source: The URL source path of the job status.
Expand Down
2 changes: 1 addition & 1 deletion runpod/error.py
Original file line number Diff line number Diff line change
@@ -1,5 +1,5 @@
"""
runpd | error.py
runpod | error.py

This file contains the error classes for the runpod package.
"""
Expand Down
2 changes: 1 addition & 1 deletion tests/test_serverless/__init__.py
Original file line number Diff line number Diff line change
@@ -1 +1 @@
""" Alow serverless tests to be run from the command line."""
""" Allow serverless tests to be run from the command line."""
4 changes: 2 additions & 2 deletions tests/test_serverless/test_modules/test_logger.py
Original file line number Diff line number Diff line change
Expand Up @@ -20,9 +20,9 @@ def test_default_log_level(self):
"""
Tests that the default log level is DEBUG
"""
defult_logger = rp_logger.RunPodLogger()
default_logger = rp_logger.RunPodLogger()

self.assertEqual(defult_logger.level, "DEBUG")
self.assertEqual(default_logger.level, "DEBUG")

def test_singleton(self):
"""
Expand Down
Loading