barretthugh

from concurrent.futures import ThreadPoolExecutor, as_completed
import json
import urllib.request

with open('webapp.json', encoding='utf-8') as f:
    config = json.loads(f.read())

URLS = [
    'http://localhost:%d/?ident=%d' % (config['port'], ident)
    for ident in range(1, 1001)

barretthugh

Lecture 1: Introduction to Research — [📝Lecture Notebooks] [▶️Video]
Lecture 2: Introduction to Python — [📝Lecture Notebooks] [▶️Video]
Lecture 3: Introduction to NumPy — [📝Lecture Notebooks] [▶️Video]
Lecture 4: Introduction to pandas — [📝Lecture Notebooks] [▶️Video]
Lecture 5: Plotting Data — [📝Lecture Notebooks] [[▶️Vide

barretthugh

"""Command line interface for monitoring asyncio tasks."""

import os
import signal
import asyncio
import argparse
import traceback
import linecache

from itertools import count

barretthugh

# aproducer.py
#
# Async Producer-consumer problem.
# Challenge: How to implement the same functionality, but no threads.

import time
from collections import deque
import heapq

class Scheduler:

barretthugh

# -*- coding: utf-8 -*-
from airflow.operators.http_operator import SimpleHttpOperator
from airflow.operators.postgres_operator import PostgresOperator
from airflow.operators.dummy_operator import DummyOperator

from airflow.hooks.postgres_hook import PostgresHook

from airflow.models import Variable, DAG

from datetime import date, datetime, timedelta

barretthugh

# -*- coding: utf-8 -*-
from airflow.operators.http_operator import SimpleHttpOperator
from airflow.operators.postgres_operator import PostgresOperator
from airflow.operators.subdag_operator import SubDagOperator
from airflow.operators.sensors import SqlSensor
from airflow.hooks.postgres_hook import PostgresHook

from airflow.operators.python_operator import PythonOperator

from airflow.models import Variable, DAG

barretthugh

def delete_dag(**kwargs):

    from airflow import models, settings
    from airflow.exceptions import AirflowException
    from sqlalchemy import or_

    dag_id = kwargs["params"]["dag_id"]
    print "Started deleting DAG id: {}".format(dag_id)
    session = settings.Session()
    DM = models.DagModel

barretthugh

# Written by Aaron Cohen -- 1/14/2013
# Brought to you by BitTorrent, Inc.
# "We're not just two guys in a basement in Sweden." TM
#
# This work is licensed under a Creative Commons Attribution 3.0 Unported License.
# See: http://creativecommons.org/licenses/by/3.0/

import sys
import re
import socket