notes/Facebook/bento_pvc.md

To Read

4 PVC tips that will make you more productive

Code

Imports

from bento import wait

import pandas as pd
import numpy as np

from fblearner.flow.api import types

DS

from datetime import date, timedelta
ds = date.today() - timedelta(days=1)

or use

from fblearner.flow.projects.pvc.date import (
    day, week,
    today, yesterday,
    date_range,
    latest_ds,
)
# All partitions from two weeks ago to the latest having landed
dataset = Dataset(
    namespace="some_namespace",
    table="some_table",
    partition=dict(
        ds=date_range(
            today() - 2 * week,
            latest_ds("some_namespace", "some_table"),
        ),
    ),
)