Skip to content

Commit

Permalink
v1.0.0
Browse files Browse the repository at this point in the history
  • Loading branch information
thearchitector committed Aug 27, 2021
1 parent 5807e45 commit f6f925b
Show file tree
Hide file tree
Showing 4 changed files with 6 additions and 4 deletions.
2 changes: 1 addition & 1 deletion docs/just_jobs/brokers/base.html
Original file line number Diff line number Diff line change
Expand Up @@ -94,7 +94,7 @@ <h3>Methods</h3>
via <code><a title="just_jobs.brokers.base.Broker.run_job" href="#just_jobs.brokers.base.Broker.run_job">Broker.run_job()</a></code>. Jobs must be dequeued atomically. This method is also
responsible for determining what to do if a job fails, like re-adding it to
the queue.</p>
<p>~ See <code>RedisBroker.process_jobs</code> for an example.</p></div>
<p>~ See <a href="https://github.com/thearchitector/just-jobs/blob/main/just_jobs/brokers/redis.py#L58">RedisBroker.process_jobs</a> for an example.</p></div>
</dd>
<dt id="just_jobs.brokers.base.Broker.run_job"><code class="name flex">
<span>async def <span class="ident">run_job</span></span>(<span>self, job: bytes) ‑> bool</span>
Expand Down
2 changes: 1 addition & 1 deletion docs/just_jobs/index.html
Original file line number Diff line number Diff line change
Expand Up @@ -183,7 +183,7 @@ <h3>Methods</h3>
via <code><a title="just_jobs.Broker.run_job" href="#just_jobs.Broker.run_job">Broker.run_job()</a></code>. Jobs must be dequeued atomically. This method is also
responsible for determining what to do if a job fails, like re-adding it to
the queue.</p>
<p>~ See <code><a title="just_jobs.RedisBroker.process_jobs" href="brokers/base.html#just_jobs.brokers.base.Broker.process_jobs">RedisBroker.process_jobs()</a></code> for an example.</p></div>
<p>~ See <a href="https://github.com/thearchitector/just-jobs/blob/main/just_jobs/brokers/redis.py#L58">RedisBroker.process_jobs</a> for an example.</p></div>
</dd>
<dt id="just_jobs.Broker.run_job"><code class="name flex">
<span>async def <span class="ident">run_job</span></span>(<span>self, job: bytes) ‑> bool</span>
Expand Down
2 changes: 1 addition & 1 deletion just_jobs/brokers/base.py
Original file line number Diff line number Diff line change
Expand Up @@ -62,7 +62,7 @@ async def process_jobs(self, queue_name: str):
responsible for determining what to do if a job fails, like re-adding it to
the queue.
~ See `RedisBroker.process_jobs` for an example.
~ See [RedisBroker.process_jobs](https://github.com/thearchitector/just-jobs/blob/main/just_jobs/brokers/redis.py#L58) for an example.
"""
raise NotImplementedError(
"Storage brokers must define a way to process queued jobs. "
Expand Down
4 changes: 3 additions & 1 deletion pyproject.toml
Original file line number Diff line number Diff line change
@@ -1,10 +1,12 @@
[tool.poetry]
name = "just-jobs"
version = "0.2.0"
version = "1.0.0"
description = "A lightweight asynchronous Python job executor backed by Redis."
authors = ["Elias Gabriel <[email protected]>"]
license = "BSD-2-Clause"
readme = "README.md"
repository = "https://github.com/thearchitector/just-jobs"
documentation = "https://thearchitector.github.io/just-jobs/just_jobs"
keywords = ["job queue", "broker", "simple", "celery", "redis"]

[tool.poetry.dependencies]
Expand Down

0 comments on commit f6f925b

Please sign in to comment.