Merge pull request 'added example for schedule, reset for demo' (#5) from develop into main
All checks were successful
Build and Push Docker Image / build-and-push (push) Successful in 2m46s
All checks were successful
Build and Push Docker Image / build-and-push (push) Successful in 2m46s
Reviewed-on: #5
This commit was merged in pull request #5.
This commit is contained in:
@@ -1,12 +1,8 @@
|
||||
from dagster import job
|
||||
from dagster import ScheduleDefinition, job
|
||||
from util_services.util_ops import preview_dataframe
|
||||
|
||||
from ..ops.ops import (
|
||||
fetch_data,
|
||||
generate_example_dataset,
|
||||
process_data,
|
||||
transform_example_dataset,
|
||||
)
|
||||
from ..ops.ops import (fetch_data, generate_example_dataset, process_data,
|
||||
transform_example_dataset)
|
||||
|
||||
|
||||
@job
|
||||
@@ -15,6 +11,15 @@ def data_processing_job():
|
||||
raw = fetch_data()
|
||||
process_data(raw)
|
||||
|
||||
data_processing_job_daily_9am = ScheduleDefinition(
|
||||
job=data_processing_job,
|
||||
cron_schedule="0 9 * * *",
|
||||
)
|
||||
|
||||
@job
|
||||
def example_job():
|
||||
original_df = generate_example_dataset()
|
||||
preview_dataframe(original_df)
|
||||
|
||||
@job
|
||||
def example_dataframe_demo_job():
|
||||
@@ -23,3 +28,5 @@ def example_dataframe_demo_job():
|
||||
preview_dataframe(original_df)
|
||||
transformed_df = transform_example_dataset(original_df)
|
||||
preview_dataframe(transformed_df)
|
||||
|
||||
|
||||
|
||||
@@ -34,7 +34,5 @@ def transform_example_dataset(df: pd.DataFrame) -> pd.DataFrame:
|
||||
df["price_band"] = df["total_price"].apply(
|
||||
lambda value: "high" if value >= 25 else "standard"
|
||||
)
|
||||
|
||||
df["total_price"] = df["quantity"] * df["unit_price"]
|
||||
|
||||
|
||||
return df
|
||||
|
||||
@@ -3,18 +3,21 @@ from dataframe_level_anonymisation.jobs import (k_anonymity_job_s3,
|
||||
l_diversity_job_s3,
|
||||
t_closeness_job_s3)
|
||||
from template_code_location.jobs.jobs import (data_processing_job,
|
||||
example_dataframe_demo_job)
|
||||
data_processing_job_daily_9am,
|
||||
example_dataframe_demo_job,
|
||||
example_job)
|
||||
from util_services.custom_json_logger import simpl_json_logger
|
||||
from util_services.resources import s3_resource
|
||||
|
||||
defs = Definitions(
|
||||
jobs=[
|
||||
#data_processing_job,
|
||||
example_dataframe_demo_job,
|
||||
example_job,
|
||||
data_processing_job,
|
||||
k_anonymity_job_s3,
|
||||
l_diversity_job_s3,
|
||||
t_closeness_job_s3,
|
||||
],
|
||||
schedules=[data_processing_job_daily_9am],
|
||||
sensors=[],
|
||||
resources={"s3": s3_resource.configured({"resource_name": "selfS3"})},
|
||||
loggers={"simpl": simpl_json_logger},
|
||||
|
||||
Reference in New Issue
Block a user