Cron Job

• Iterate computations, queries and actions on a crontab
• Can be deployed on Superduper Enterprise

Usage pattern

Cron-job can take any actions relating to db which is loaded as an attribute of the Component.

import datetime
from superduper.components.cron_job import CronJob

class MyCronJob(CronJob):
    table: str

    # overwriting this function defines actions to be 
    # taken on a schedule
    def run(self):
        results = list(self.db[self.table].select())

        date = str(datetime.now())

        with open(f'{date}.bak', 'wb') as f:
            json.dump(results)
        
        # for example, backing up a collection every day
        os.system(f'aws s3 cp {date}.bak s3://my-bucket/{date}.bak')

cron_job = MyCronJob(table='documents', schedule='0 0 * * * *')

db.apply(cron_job)