osmanmesutozcan

import logging

from django.contrib.gis.db.backends.postgis.base import \
    DatabaseWrapper as PostgisDBWrapper
from django.db import ProgrammingError

from .schema import TimescaleSchemaEditor

logger = logging.getLogger(__name__)

osmanmesutozcan

# install nix (5.5 mins)
curl https://nixos.org/nix/install | sh

# open a new shell to source nix
bash

# query available haskell compilers
nix-env -qaP -A nixpkgs.haskell.compiler [QUERY]

# install ghc (2.5 mins, cached binary)

osmanmesutozcan

Quick demo of implementing pipelines via Celery

How to use

1. Install Celery and Redis
2. Start your redis locally
3. Run three workers with name worker1@localhost, worker2@localhost and worker3@localhost
4. Run the main.py

Improvements made to the original version