Skip to main content

Use async to have functions run on a schedule.

Project description

Use async to have functions run on a schedule.

Example

Async Sched can run tasks on a schedule. It can also receive new tasks (in limited fashion) and change the running schedules without stopping the service.

scheduler.py
schedules/
    task1.py
    task2.py
# scheduler.py
import async_sched

srv = async_sched.start_server(('127.0.0.1', 8000),
                               update_path='./schedules',
                               global_server=True)

# srv.add('3 Second', async_sched.Schedule(seconds=3), print, 'Hello 3 seconds')

srv.run_forever()

Task 1 in the schedules directory will automatically be imported. Because start_server sets the server as an accessible attribute with get_server we can dynamically add schedules.

# schedules/task1.py
from async_sched import get_server, Schedule
import datetime


def print_task1():
    print('Hello! I am task 1 ' + str(datetime.datetime.now()))

s = Schedule(seconds=30, repeat=True)

# This will remove an existing 'Task 1' and schedule a new 'Task 1'
server = get_server()
server.add('Task 1', s, print_task1)

In the task 2 file we are not scheduling any commands, but we are registering a callback function that can be run from a client later.

# schedules/task2.py
from async_sched import get_server, Schedule
import datetime

server = get_server()


@server.register_callback  # or @server.register_callback('print_task2')
def print_task2(name):
    print('Task 2 is running! ', name, str(datetime.datetime.now()))

Now run the scheduler server to listen to remote commands and manage the running schedules.

python scheduler.py

# or python -m async_sched.server.run –path “schedules” –host “127.0.0.1” –port 8000

Use a client to print the running schedules.

python -m async_sched.client.request_schedules –host “127.0.0.1” –port 8000

Reload the files in the ./schedules/ directory.

python -m async_sched.client.update server –host “127.0.0.1” –port 8000

Stop a schedule that is running.

python -m async_sched.client.stop_schedule “Task 1” –host “127.0.0.1” –port 8000

Run a registered callback function.

python -m async_sched.client run_command “print_task2” “hello” –host “127.0.0.1” –port 8000

Schedule a registered command.

python -m async_sched.client schedule_command “print_task2” “hello” –seconds 10 –host “127.0.0.1” –port 8000

Project details


Download files

Download the file for your platform. If you're not sure which to choose, learn more about installing packages.

Source Distribution

async_sched-1.2.5.tar.gz (17.7 kB view details)

Uploaded Source

Built Distribution

async_sched-1.2.5-py3-none-any.whl (60.4 kB view details)

Uploaded Python 3

File details

Details for the file async_sched-1.2.5.tar.gz.

File metadata

  • Download URL: async_sched-1.2.5.tar.gz
  • Upload date:
  • Size: 17.7 kB
  • Tags: Source
  • Uploaded using Trusted Publishing? No
  • Uploaded via: twine/3.1.1 pkginfo/1.5.0.1 requests/2.23.0 setuptools/47.1.1 requests-toolbelt/0.9.1 tqdm/4.46.1 CPython/3.8.1

File hashes

Hashes for async_sched-1.2.5.tar.gz
Algorithm Hash digest
SHA256 0c6e51e4fc1a99ac986bbf4fe6b5b382c04f01e10c7c82584194b068ff03393a
MD5 78c74a3054375359fda0ed8de6e74609
BLAKE2b-256 97ad9ff4d09d4171d817489876b42dc3123c0e0e1307dd87b4702ef222a403c5

See more details on using hashes here.

File details

Details for the file async_sched-1.2.5-py3-none-any.whl.

File metadata

  • Download URL: async_sched-1.2.5-py3-none-any.whl
  • Upload date:
  • Size: 60.4 kB
  • Tags: Python 3
  • Uploaded using Trusted Publishing? No
  • Uploaded via: twine/3.1.1 pkginfo/1.5.0.1 requests/2.23.0 setuptools/47.1.1 requests-toolbelt/0.9.1 tqdm/4.46.1 CPython/3.8.1

File hashes

Hashes for async_sched-1.2.5-py3-none-any.whl
Algorithm Hash digest
SHA256 2a8324994e0a5f0daacdbb3776529693690112b12519d227536079e51e855307
MD5 bed070b4ff2463c84ed0efb1f46bb0f8
BLAKE2b-256 b8782d6a39f1efdf051a12decfdeab09b1d6779947bdff9752eee6c6024c6aed

See more details on using hashes here.

Supported by

AWS AWS Cloud computing and Security Sponsor Datadog Datadog Monitoring Fastly Fastly CDN Google Google Download Analytics Microsoft Microsoft PSF Sponsor Pingdom Pingdom Monitoring Sentry Sentry Error logging StatusPage StatusPage Status page