@@ -2992,6 +2992,7 @@ instance ToJSON StepProperties where
29922992-- /See:/ 'topologyConfig' smart constructor.
29932993data TopologyConfig = TopologyConfig'
29942994 { _tcDataDiskAssignments :: !(Maybe [DataDiskAssignment])
2995+ , _tcPersistentStateVersion :: !(Maybe (Textual Int32))
29952996 , _tcForwardingKeyBits :: !(Maybe (Textual Int32))
29962997 , _tcUserStageToComputationNameMap :: !(Maybe TopologyConfigUserStageToComputationNameMap)
29972998 , _tcComputations :: !(Maybe [ComputationTopology])
@@ -3003,6 +3004,8 @@ data TopologyConfig = TopologyConfig'
30033004--
30043005-- * 'tcDataDiskAssignments'
30053006--
3007+-- * 'tcPersistentStateVersion'
3008+--
30063009-- * 'tcForwardingKeyBits'
30073010--
30083011-- * 'tcUserStageToComputationNameMap'
@@ -3013,6 +3016,7 @@ topologyConfig
30133016topologyConfig =
30143017 TopologyConfig'
30153018 { _tcDataDiskAssignments = Nothing
3019+ , _tcPersistentStateVersion = Nothing
30163020 , _tcForwardingKeyBits = Nothing
30173021 , _tcUserStageToComputationNameMap = Nothing
30183022 , _tcComputations = Nothing
@@ -3026,6 +3030,13 @@ tcDataDiskAssignments
30263030 . _Default
30273031 . _Coerce
30283032
3033+-- | Version number for persistent state.
3034+tcPersistentStateVersion :: Lens' TopologyConfig (Maybe Int32)
3035+tcPersistentStateVersion
3036+ = lens _tcPersistentStateVersion
3037+ (\ s a -> s{_tcPersistentStateVersion = a})
3038+ . mapping _Coerce
3039+
30293040-- | The size (in bits) of keys that will be assigned to source messages.
30303041tcForwardingKeyBits :: Lens' TopologyConfig (Maybe Int32)
30313042tcForwardingKeyBits
@@ -3053,7 +3064,8 @@ instance FromJSON TopologyConfig where
30533064 (\ o ->
30543065 TopologyConfig' <$>
30553066 (o .:? "dataDiskAssignments" .!= mempty) <*>
3056− (o .:? "forwardingKeyBits")
3067+ (o .:? "persistentStateVersion")
3068+ <*> (o .:? "forwardingKeyBits")
30573069 <*> (o .:? "userStageToComputationNameMap")
30583070 <*> (o .:? "computations" .!= mempty))
30593071
@@ -3063,6 +3075,8 @@ instance ToJSON TopologyConfig where
30633075 (catMaybes
30643076 [("dataDiskAssignments" .=) <$>
30653077 _tcDataDiskAssignments,
3078+ ("persistentStateVersion" .=) <$>
3079+ _tcPersistentStateVersion,
30663080 ("forwardingKeyBits" .=) <$> _tcForwardingKeyBits,
30673081 ("userStageToComputationNameMap" .=) <$>
30683082 _tcUserStageToComputationNameMap,
@@ -4737,6 +4751,7 @@ instance ToJSON SinkSpec where
47374751-- /See:/ 'workerPool' smart constructor.
47384752data WorkerPool = WorkerPool'
47394753 { _wpAutoscalingSettings :: !(Maybe AutoscalingSettings)
4754+ , _wpNumThreadsPerWorker :: !(Maybe (Textual Int32))
47404755 , _wpDiskSizeGb :: !(Maybe (Textual Int32))
47414756 , _wpKind :: !(Maybe Text)
47424757 , _wpTaskrunnerSettings :: !(Maybe TaskRunnerSettings)
@@ -4763,6 +4778,8 @@ data WorkerPool = WorkerPool'
47634778--
47644779-- * 'wpAutoscalingSettings'
47654780--
4781+-- * 'wpNumThreadsPerWorker'
4782+--
47664783-- * 'wpDiskSizeGb'
47674784--
47684785-- * 'wpKind'
@@ -4803,6 +4820,7 @@ workerPool
48034820workerPool =
48044821 WorkerPool'
48054822 { _wpAutoscalingSettings = Nothing
4823+ , _wpNumThreadsPerWorker = Nothing
48064824 , _wpDiskSizeGb = Nothing
48074825 , _wpKind = Nothing
48084826 , _wpTaskrunnerSettings = Nothing
@@ -4829,6 +4847,16 @@ wpAutoscalingSettings
48294847 = lens _wpAutoscalingSettings
48304848 (\ s a -> s{_wpAutoscalingSettings = a})
48314849
4850+-- | The number of threads per worker harness. If empty or unspecified, the
4851+-- service will choose a number of threads (according to the number of
4852+-- cores on the selected machine type for batch, or 1 by convention for
4853+-- streaming).
4854+wpNumThreadsPerWorker :: Lens' WorkerPool (Maybe Int32)
4855+wpNumThreadsPerWorker
4856+ = lens _wpNumThreadsPerWorker
4857+ (\ s a -> s{_wpNumThreadsPerWorker = a})
4858+ . mapping _Coerce
4859+
48324860-- | Size of root disk for VMs, in GB. If zero or unspecified, the service
48334861-- will attempt to choose a reasonable default.
48344862wpDiskSizeGb :: Lens' WorkerPool (Maybe Int32)
@@ -4960,7 +4988,8 @@ instance FromJSON WorkerPool where
49604988 (\ o ->
49614989 WorkerPool' <$>
49624990 (o .:? "autoscalingSettings") <*>
4963− (o .:? "diskSizeGb")
4991+ (o .:? "numThreadsPerWorker")
4992+ <*> (o .:? "diskSizeGb")
49644993 <*> (o .:? "kind")
49654994 <*> (o .:? "taskrunnerSettings")
49664995 <*> (o .:? "numWorkers")
@@ -4985,6 +5014,8 @@ instance ToJSON WorkerPool where
49855014 (catMaybes
49865015 [("autoscalingSettings" .=) <$>
49875016 _wpAutoscalingSettings,
5017+ ("numThreadsPerWorker" .=) <$>
5018+ _wpNumThreadsPerWorker,
49885019 ("diskSizeGb" .=) <$> _wpDiskSizeGb,
49895020 ("kind" .=) <$> _wpKind,
49905021 ("taskrunnerSettings" .=) <$> _wpTaskrunnerSettings,