pvsune

import logging
from multiprocessing import Pool, TimeoutError


logging.basicConfig(level=logging.INFO)


def timeout(func, args=None, kwds=None, timeout=10):
    """Call function and wait until timeout.

pvsune

#!/usr/bin/env python
import logging
import os
import threading
import time
from multiprocessing import Process
from queue import Queue

from confluent_kafka import Consumer

pvsune

import json

from django.conf import settings
from django.contrib.postgres.fields import (
    JSONField as DjangoJSONField,
    ArrayField as DjangoArrayField,
)
from django.db.models import Field

pvsune

kind: pipeline
name: default

steps:
- name: publish
  image: plugins/ecr
  environment:
    PLUGIN_STORAGE_DRIVER: overlay2
    PLUGIN_CACHE_FROM: xxxxx.dkr.ecr.ap-southeast-1.amazonaws.com/pvsune/myapp:latest
  settings: