@@ -30,27 +30,43 @@ Parameters:
3030 DefaultWorkerType:
3131 Type: String
3232 Description: >-
33- Which worker type to use for this job.
33+ Which worker type to use for most data types
3434 Default: 'Standard'
3535
36- LargeJobWorkerType :
36+ MediumJobWorkerType :
3737 Type: String
3838 Description: >-
3939 Which worker type to use for this job.
40+ Medium data types include: HealthKitV2Samples, HealthKitV2Electrocardiogram,
41+ FitbitDailyData, FitbitSleepLogs
4042 Default: 'G.4X'
4143
44+ LargeJobWorkerType:
45+ Type: String
46+ Description: >-
47+ Which worker type to use for this job.
48+ Large data types include: FitbitIntradayCombined
49+ Default: 'G.8X'
50+
4251 DefaultNumberOfWorkers:
4352 Type: Number
4453 Description: >-
45- How many DPUs to allot to this job. This parameter is not used for types
46- FitbitIntradayCombined and HealthKitV2Samples.
54+ How many DPUs to allot for most data types.
4755 Default: 1
4856
57+ MediumJobNumberOfWorkers:
58+ Type: Number
59+ Description: >-
60+ How many DPUs to allot to this job.
61+ Medium data types include: HealthKitV2Samples, HealthKitV2Electrocardiogram,
62+ FitbitDailyData, FitbitSleepLogs
63+ Default: 4
64+
4965 LargeJobNumberOfWorkers:
5066 Type: Number
5167 Description: >-
52- How many DPUs to allot to this job. This parameter overrides `DefaultNumberOfWorkers`
53- for data types FitbitIntradayCombined and HealthKitV2Samples.
68+ How many DPUs to allot to this job.
69+ Large data types include: FitbitIntradayCombined
5470 Default: 8
5571
5672 MaxRetries:
@@ -110,13 +126,17 @@ Resources:
110126 GlueVersion: !Ref GlueVersion
111127 MaxRetries: !Ref MaxRetries
112128 Name: !Sub "${Namespace}-{{ dataset["stackname_prefix"] }}-Job"
113- {% if (
129+ {% if dataset ["type" ] == "FitbitIntradayCombined" -%}
130+ WorkerType: !Ref LargeJobWorkerType
131+ NumberOfWorkers: !Ref LargeJobNumberOfWorkers
132+ {% elif (
114133 dataset ["type" ] == "HealthKitV2Samples"
115- or dataset ["type" ] == "FitbitIntradayCombined"
116134 or dataset ["type" ] == "HealthKitV2Electrocardiogram"
135+ or dataset ["type" ] == "FitbitDailyData"
136+ or dataset ["type" ] == "FitbitSleepLogs"
117137 ) -%}
118- WorkerType: !Ref LargeJobWorkerType
119- NumberOfWorkers: !Ref LargeJobNumberOfWorkers
138+ WorkerType: !Ref MediumJobWorkerType
139+ NumberOfWorkers: !Ref MediumJobNumberOfWorkers
120140 {% else -%}
121141 WorkerType: !Ref DefaultWorkerType
122142 NumberOfWorkers: !Ref DefaultNumberOfWorkers
0 commit comments