jcrist

from prefect import Flow
from prefect.environments.execution import KubernetesJobEnvironment
from prefect.environments.storage import Docker

with Flow("kubernetes-example") as flow:
    # Add tasks to flow here...
    
# Run on Kubernetes using a custom job specification
# This was needed to do even simple things like increase
# the job resource limits

jcrist

In [3]: from typing import NamedTuple

In [4]: from quickle import Struct

In [5]: from dataclasses import dataclass

In [6]: class PointTuple(NamedTuple):
   ...:     x: int
   ...:     y: int
   ...:

jcrist

import typing
import inspect


def _extract_attributes(bases, attrs):
    arg_fields = {}
    kwarg_fields = {}
    existing_slots = set()

    # Walk up the bases, validating and merging defaults

jcrist

Dask SciPy Sprints 2020

Hello! Welcome to the Dask sprints for SciPy 2020.

Getting started contributing

Here's a few links for getting started contributing:

• Our contributor guide is here. This should cover

jcrist

import pickle
import struct


class Memo(object):
    def __init__(self):
        self.kv = {}

    def put(self, item):
        ind = self.kv[id(item)] = len(self.kv)

jcrist

import beeline
from starlette.exceptions import HTTPException

from starlette.datastructures import Headers


class HoneycombMiddleware:
    def __init__(self, app):
        self.app = app

jcrist

jcrist

import ctypes

import numpy as np
from numba.extending import get_cython_function_address, overload, intrinsic
from numba.errors import TypingError
from numba import cgutils, types

import scipy.special

jcrist

jcrist

FROM ubuntu:xenial

RUN apt-get update && \
    apt-get install -y -q curl bzip2 git && \
    rm -rf /var/lib/apt/lists/*

# Install CDH5 in a single node: Pseudo Distributed
# Docs: https://www.cloudera.com/documentation/enterprise/5-6-x/topics/cdh_qs_yarn_pseudo.html
ADD cloudera.pref /etc/apt/preferences.d/cloudera.pref
RUN curl -s https://archive.cloudera.com/cdh5/ubuntu/xenial/amd64/cdh/archive.key | apt-key add - && \