sprzedwojski

Array

• Two Sum
• Best Time to Buy and Sell Stock
• Contains Duplicate
• Product of Array Except Self
• Maximum Subarray
• Maximum Product Subarray
• Find Minimum in Rotated Sorted Array

sprzedwojski

from airflow.utils import dates
from airflow.contrib.operators import dataproc_operator
from airflow import models
from airflow.utils.trigger_rule import TriggerRule
from o2a_libs.el_basic_functions import *
from airflow.operators import bash_operator
import datetime
from o2a_libs.el_wf_functions import *
from airflow.operators import dummy_operator

sprzedwojski

from airflow.contrib.operators import dataproc_operator
from airflow.utils.trigger_rule import TriggerRule
from airflow.utils import dates
from airflow import models
from airflow.operators import bash_operator
import datetime

PARAMS = {
    "user.name": "TODO",
    "nameNode": "hdfs://",

sprzedwojski

from airflow.contrib.operators import dataproc_operator
from airflow.utils import dates
from airflow import models
import datetime
from airflow.operators import bash_operator
from airflow.utils.trigger_rule import TriggerRule

PARAMS = {
    "user.name": "szymon",
    "nameNode": "hdfs://localhost:8020",

sprzedwojski

# DECORATORS
# https://realpython.com/primer-on-python-decorators/

# Calling higher-order functions.
# A function that takes another function and extends its behaviour (without modifying it).
import functools


def my_decorator(func):
    @functools.wraps(func)

sprzedwojski

product_set_id = 'my-product-set-1'

product_set_create = CloudVisionProductSetCreateOperator(
    product_set_id=product_set_id
    # ...
)

for x in range(0, 1000):
    product_create = CloudVisionProductCreateOperator(
        product_id='my-product-{}'.format(x),