FazBrowse GitHub Viewer
|
Trending
|
URL:
|
Home
Tools:
[Download Repo ZIP]
[View Raw Code]
[Original HTTPS Page]
python_queue_benchmark/taskiq/tasks.py at main · steventen/python_queue_benchmark · GitHub
steventen
/
python_queue_benchmark
Public
Notifications
You must be signed in to change notification settings
Fork
2
Star
12
Code
Issues
0
Pull requests
0
Actions
Projects
Security and quality
0
Insights
Additional navigation options
Code
Issues
Pull requests
Actions
Projects
Security and quality
Insights
Expand file tree
Breadcrumbs
python_queue_benchmark
/
taskiq
/
tasks.py
Copy path
More file actions
More file actions
Latest commit
History
History
History
11 lines (8 loc) · 243 Bytes
Breadcrumbs
python_queue_benchmark
/
taskiq
/
tasks.py
Copy path
File metadata and controls
11 lines (8 loc) · 243 Bytes
Raw
Copy raw file
Download raw file
Open symbols panel
Edit and raw actions
1
2
3
4
5
6
7
8
9
10
11
import
time
from
taskiq_redis
import
RedisStreamBroker
broker
=
RedisStreamBroker
(
url
=
"redis://localhost:6379"
)
@
broker
.
task
async
def
load_test_job
(
num
):
end_time
=
time
.
time
()
print
(
f"Job
{
num
}
finished at
{
end_time
}
"
)
return
Back
|
FazBrowse Home
|
New Git URL