cdeil

cdeil

from sqlalchemy import JSON
from sqlalchemy import Column
from sqlalchemy import Enum
from sqlalchemy import Float
from sqlalchemy import ForeignKey
from sqlalchemy import Integer
from sqlalchemy import String
from sqlalchemy.ext.declarative import declarative_base
from sqlalchemy.orm import relationship

cdeil

/Users/cdeil/opt/anaconda3/envs/hpred/bin/python /Users/cdeil/code/hc/hpred/python_interpreter_info.py
{'PATH': ['/Users/cdeil/opt/anaconda3/envs/hpred/bin',
          '/Users/cdeil/opt/anaconda3/condabin',
          '/usr/local/opt/node@12/bin',
          '/usr/local/bin',
          '/usr/bin',
          '/bin',
          '/usr/sbin',
          '/sbin',
          '/usr/local/share/dotnet',

cdeil

"""Prefect scheduling example in Orion"""
import datetime
import subprocess

from prefect import task, flow
from prefect.client import OrionClient
from prefect.deployments import DeploymentSpec, create_deployment_from_spec
from prefect.orion.services.scheduler import Scheduler
from prefect.orion.schemas.schedules import IntervalSchedule

cdeil

% conda list
# packages in environment at /Users/cdeil/opt/anaconda3/envs/prefect-tutorial:
#
# Name                    Version                   Build  Channel
_anaconda_depends         2021.11                  py39_0  
alabaster                 0.7.12             pyhd3eb1b0_0  
anaconda                  custom                   py39_1  
anaconda-client           1.9.0            py39hecd8cb5_0  
anaconda-project          0.10.2             pyhd3eb1b0_0  
anyio                     2.2.0            py39hecd8cb5_1  

cdeil

from prefect import task, Flow, Parameter


@task
def print_plus_one(x):
    print(x + 1)


def flow(name):
    def inner(fn):

cdeil

import click
import pandas as pd
import urllib3
from influxdb_client import InfluxDBClient
from influxdb_client import WriteOptions


def read_parquet_file(plant_id: str, tag: str):
    path = f"{plant_id}/parquet/{tag}.parquet"
    print(f"importing {path}")

cdeil

% pip freeze
aiohttp @ file:///Users/runner/miniforge3/conda-bld/aiohttp_1605734434303/work
aliyun-python-sdk-core @ file:///Users/runner/miniforge3/conda-bld/aliyun-python-sdk-core_1606717052129/work
aliyun-python-sdk-kms @ file:///home/conda/feedstock_root/build_artifacts/aliyun-python-sdk-kms_1606460652868/work
ansi2html @ file:///Users/runner/miniforge3/conda-bld/ansi2html_1605638367911/work
appdirs @ file:///home/conda/feedstock_root/build_artifacts/appdirs_1603108395799/work
appnope @ file:///Users/runner/miniforge3/conda-bld/appnope_1606850125884/work
argcomplete @ file:///home/conda/feedstock_root/build_artifacts/argcomplete_1606202836286/work
argon2-cffi @ file:///Users/runner/miniforge3/conda-bld/argon2-cffi_1605217150745/work
async-generator==1.10

cdeil

print("hello azure jobs")

cdeil