mianos

#!/usr/bin/env python3
import sys

import pulsar
import argparse


# pulsar_host = "http://10.217.0.171:9080"
pulsar_host = "http://131.84.1.232"

mianos

volumes:
  persistence: true

# disabled AntiAffinity
affinity:
  anti_affinity: false

# disable auto recovery
components:
  autorecovery: false

mianos

from typing import Any, Callable
import concurrent.futures

from prefect.engine.executors.base import Executor


class CFExecutor(Executor):
    def __init__(self):
        print("Robexecutor")
        self.pool =  concurrent.futures.ThreadPoolExecutor(3)

mianos

python slow.py --range=10 --sleep_time=3
[2020-10-15 03:40:32] INFO - prefect.FlowRunner | Beginning Flow run for 'PS Version'
[2020-10-15 03:40:32] INFO - prefect.TaskRunner | Task 'scripts': Starting task run...
[2020-10-15 03:40:32] INFO - prefect.TaskRunner | Task 'scripts': finished task run for task with final state: 'Success'
[2020-10-15 03:40:32] INFO - prefect.TaskRunner | Task 'opts': Starting task run...
[2020-10-15 03:40:32] INFO - prefect.TaskRunner | Task 'opts': finished task run for task with final state: 'Success'
[2020-10-15 03:40:32] INFO - prefect.TaskRunner | Task 'produce_range': Starting task run...
[2020-10-15 03:40:32] INFO - prefect.TaskRunner | Task 'produce_range': finished task run for task with final state: 'Success'
[2020-10-15 03:40:32] INFO - prefect.TaskRunner | Task 'slow_task': Starting task run...
[2020-10-15 03:40:32] INFO - prefect.TaskRunner | Task 'slow_task': finished task run for task with final state: 'Mapped'

mianos

import time

STATE_PRIMARY = 1
STATE_BACKUP = 2
STATE_ACTIVE = 3
STATE_PASSIVE = 4

PEER_PRIMARY = 1
PEER_BACKUP = 2
PEER_ACTIVE = 3

mianos

Keybase proof

I hereby claim:

• I am mianos on github.
• I am robfowler (https://keybase.io/robfowler) on keybase.
• I have a public key ASD9yrKlE0QJCCrnQz-gIao7aw_dxSFV6yfUA1C-SOJlbAo

To claim this, I am signing this object:

mianos

#include <Arduino.h>

#define _TASK_LTS_POINTER
#include <TaskScheduler.h>

class STT {
    static Scheduler *gts;
    Task *test_task;
    int counter;
public:

mianos

from flask import Blueprint, render_template, request, flash, jsonify, current_app
# from flask.ext.login import login_required
import requests
import xmltodict

from menu import add_menu
from jsonp import support_jsonp
from cnabort import abort

import forms

mianos

import sys

sys.path.append('dispatch-on-value-for-python')

import dispatchonvalue as dispatchonvalue


# Register your overloaded functions:
class abc:
    dispatch_on_value = dispatchonvalue.DispatchOnValue()

mianos

#include "os_type.h"
#include "user_interface.h"

#include "ets_alt_task.h"
#include "os_task.h"

STATIC os_event_t sensor_evt_queue[16];

STATIC ICACHE_FLASH_ATTR void esp_os_task_print(const mp_print_t *print, mp_obj_t self_in, mp_print_kind_t kind) {
    esp_os_task_obj_t *self = self_in;