Merge branch 'main' of https://github.com/GoodManWEN/fastapi-queue

Author: GoodManWEN

.github/workflows/python-package.yml

@@ -22,8 +22,8 @@ jobs:
     runs-on: ${{ matrix.os }}
     strategy:
       matrix:
-        os: [macos-latest, ubuntu-latest, windows-latest]
-        python-version: ['3.7' , '3.8' , '3.9']
+        os: [ubuntu-latest,]
+        python-version: ['3.7' , '3.8' , '3.9', '3.10']
 
     steps:
     - uses: actions/checkout@v2

README.md

@@ -203,9 +203,9 @@ if __name__ == '__main__':
 
 Due to the fully asynchronous support, complex interprocedural calls exhibit a very low processing latency.
 
-(Latency vs. number of request threads)
+(Latency vs. number of request threads on going)
 
-(Maximum capability requests per second vs. number of service nodes)
+(Maximum capability requests per second vs. number of service nodes on going)
 
 ## Tips
 
@@ -232,7 +232,13 @@ async def startup():
 @RateLimiter(bucket = 5000, limits_s = 1000)
 async def root(request: Request):  
     '''
-    The two parameters of RateLimiter mean that this particular FastAPI instance holds a total of 5000 tokens and takes one token each time a request is received. If there is a large influx of requests come in a short period of time, when the number of remaining tokens in the bucket decreases to 0, the server will simply reject all requests without forwarding them to the queue-worker. With current parameters, this bucket now keeps a maximum of 5000 tokens and restores 1000 tokens per second.
+    The two parameters of RateLimiter mean that this particular FastAPI instance 
+    holds a total of 5000 tokens and takes one token each time a request is received. 
+    If there is a large influx of requests come in a short period of time, when 
+    the number of remaining tokens in the bucket decreases to 0, the server will 
+    simply reject all requests without forwarding them to the queue-worker. With 
+    current parameters, this bucket now keeps a maximum of 5000 tokens and restores 
+    1000 tokens per second.
     '''
     async with DistributedTaskApplyManager(
         ...

setup.py

@@ -86,5 +86,5 @@ def get_install_requires(filename):
         'Framework :: AsyncIO',
     ],
     python_requires='>=3.7',
-    keywords=["fastapi-queue" ,]
+    keywords=["fastapi-queue" , "fastapi", "queue"]
 )