Class: GoodData::LCM2::SynchronizeComputedAttributes
- Inherits:
-
BaseAction
- Object
- BaseAction
- GoodData::LCM2::SynchronizeComputedAttributes
- Defined in:
- lib/gooddata/lcm/actions/synchronize_cas.rb
Constant Summary collapse
- DESCRIPTION =
'Synchronize Computed Attributes'
- PARAMS =
define_params(self) do description 'Client Used for Connecting to GD' param :gdc_gd_client, instance_of(Type::GdClientType), required: true description 'Synchronization Info' param :synchronize, array_of(instance_of(Type::SynchronizationInfoType)), required: true, generated: true description 'Specifies whether to transfer computed attributes' param :include_computed_attributes, instance_of(Type::BooleanType), required: false, default: true description 'Logger' param :gdc_logger, instance_of(Type::GdLogger), required: true description 'Additional Hidden Parameters' param :additional_hidden_params, instance_of(Type::HashType), required: false end
Constants included from Dsl::Dsl
Dsl::Dsl::DEFAULT_OPTS, Dsl::Dsl::TYPES
Class Method Summary collapse
Methods inherited from BaseAction
Methods included from Dsl::Dsl
#define_params, #define_type, #process
Class Method Details
.call(params) ⇒ Object
38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 |
# File 'lib/gooddata/lcm/actions/synchronize_cas.rb', line 38 def call(params) # set default value for include_computed_attributes # (we won't have to do this after TMA-690) include_ca = params.include_computed_attributes include_ca = true if include_ca.nil? include_ca = include_ca.to_b results = [] return results unless include_ca client = params.gdc_gd_client params.synchronize.each do |info| from = info.from to_projects = info.to params.gdc_logger.info "Synchronize Computed Attributes from project pid: #{from}" to_projects.peach do |entry| ca_scripts = entry[:ca_scripts] next unless ca_scripts pid = entry[:pid] ca_chunks = ca_scripts[:maqlDdlChunks] to_project = client.projects(pid) || fail("Invalid 'to' project specified - '#{pid}'") params.gdc_logger.info "Synchronizing Computed Attributes to project: '#{to_project.title}', PID: #{pid}" begin ca_chunks.each { |chunk| to_project.execute_maql(chunk) } rescue => e raise "Error occured when executing MAQL, project: \"#{to_project.title}\" reason: \"#{e.}\", chunks: #{ca_chunks.inspect}" end results << { from: from, to: pid, status: 'ok' } end end results end |