@@ -56,7 +56,6 @@ func init() {
5656 flags .AddCSVSeparator (createCmd )
5757 addLocationFlag (createCmd , "Location ID. If no ID is specified, closest location to you is used by default." )
5858 addWaitFlag (createCmd , "Wait for the database to be ready to receive requests." )
59- addCanaryFlag (createCmd )
6059 addEnableExtensionsFlag (createCmd )
6160 addSchemaFlag (createCmd )
6261 addTypeFlag (createCmd )
@@ -142,18 +141,13 @@ func CreateDatabase(name string) error {
142141 return err
143142 }
144143
145- seed , err = parseDBSeedFlags (client , isAWS , remoteEncryptionCipherFlag )
144+ seed , err = parseDBSeedFlags (client , isAWS , remoteEncryptionCipherFlag , multipartFlag )
146145 if err != nil {
147146 return err
148147 }
149148 }
150149
151- version := "latest"
152- if canaryFlag {
153- version = "canary"
154- }
155-
156- if err := ensureGroup (client , groupName , groups , location , version ); err != nil {
150+ if err := ensureGroup (client , groupName , groups , location , "latest" ); err != nil {
157151 return err
158152 }
159153
@@ -287,8 +281,12 @@ func validateEncryptionFlags() error {
287281 }
288282
289283 // if cipher is empty, then it is only valid in case of forks and for everything else we need to have it set
290- if remoteEncryptionCipherFlag == "" && fromDBFlag == "" {
291- return fmt .Errorf ("remote encryption cipher must be provided when remote encryption key is set" )
284+ if remoteEncryptionCipherFlag == "" {
285+ if fromDBFlag == "" {
286+ return fmt .Errorf ("remote encryption cipher must be provided when remote encryption key is set" )
287+ }
288+ // for forks, cipher can be derived from source database
289+ return nil
292290 }
293291
294292 if ! isValidCipher (remoteEncryptionCipherFlag ) {
0 commit comments