Skip to content

Commit 95d47c3

Browse files
committed
Tweak definitions
1 parent 684cccf commit 95d47c3

File tree

1 file changed

+7
-18
lines changed

1 file changed

+7
-18
lines changed

dg_projects/learning_resources/learning_resources/definitions.py

Lines changed: 7 additions & 18 deletions
Original file line numberDiff line numberDiff line change
@@ -58,26 +58,15 @@
5858
execution_timezone="Etc/UTC",
5959
)
6060

61-
# YouTube Shorts assets selection
62-
youtube_shorts_assets = AssetSelection.assets(
63-
youtube_video_metadata,
64-
youtube_video_content,
65-
youtube_video_thumbnail,
66-
)
67-
6861
# Create YouTube Shorts job for manual execution
6962
youtube_shorts_job = define_asset_job(
7063
name="youtube_shorts_job",
71-
selection=youtube_shorts_assets,
72-
config={
73-
"resources": {
74-
"youtube_shorts_config": {
75-
"config": {
76-
"bucket_name": os.getenv("LR_VIDEO_SHORTS_BUCKET"),
77-
}
78-
}
79-
}
80-
},
64+
selection=AssetSelection.assets(
65+
youtube_video_metadata,
66+
youtube_video_content,
67+
youtube_video_thumbnail,
68+
youtube_webhook,
69+
),
8170
)
8271

8372

@@ -86,7 +75,7 @@
8675
resources={
8776
"io_manager": default_io_manager(DAGSTER_ENV),
8877
"s3file_io_manager": S3FileObjectIOManager(
89-
bucket=os.environ.get("LR_VIDEO_SHORTS_BUCKET"),
78+
bucket=os.environ.get("YOUTUBE_SHORTS_BUCKET"),
9079
path_prefix="youtube_shorts",
9180
),
9281
"vault": vault,

0 commit comments

Comments
 (0)