Netflix / conductor

70%

master: 70%

LAST BUILD ON BRANCH bugfix/poll_with_concurrency_limits

branch: bugfix/poll_with_concurrency_limits

CHANGE BRANCH

x

Reset

• bugfix/poll_with_concurrency_limits
• 2.31
• 3.0
• ack_asyncComplete_system_tasks
• action-close-stale-issues-prs
• add_executeSystemTasks_tests
• add_pending_metric
• add_restart_with_latest_definition_to_client
• add_workflow_consistency_docs
• allow_event_processor_extension
• allow_retry_task_failed_with_terminal_error
• allow_task_defs_system_tasks
• apanicker-nflx-patch-1
• api_fix
• append_decision_caseexpression_test
• async_complete_system_task_integration_test
• async_decide_with_sweeper
• backport_terminate_task_fix
• bug_fixes
• bugfix/apply-filters-to-search-by-task
• bugfix/dynamic_fork_join_task_validation
• bugfix/external_payload_storage_rendering_from_subworkflow
• bugfix/gulp_build_failure
• bugfix/queue_exceptions_during_terminate_workflow
• bugfix/retry_workflow_update_task
• bugfix/subworkflow-not-rendering
• bugfix/support_env_variable_task_input_param
• bugfix/system_tasks_repair
• bugfix/task-search-doesnt-search-entire-string-during-fallback
• bugfix/task_subworkflow_id_deep_copy
• bugfix/unable-to-render-running-workflow
• bugfix/unencoded-url-params
• build_clean_up_move_mysql_postgres_to_docker
• cass_consistency_level
• cass_event_execution
• cass_metadata_dao
• cassandra_concurrent_exec_limit
• cassandra_dao_impl
• cassandra_execution_dao_invalid_checks
• cassandra_lwt_workflow_update_counter
• cleanup
• cleanup_logs_safeguard_removal
• cleanup_subworkflowId_on_task_retry
• cleanup_to_support_generic_queue_implementations
• client_retry_external_payload_fix
• client_taskdomain_taskrunnerconfigurer
• compatibility_fix
• configurable_zk_timeouts
• cosmetic_changes
• decision_integration_test
• decision_within_fork_join
• dedup_tasks_during_scheduling
• dependabot/npm_and_yarn/ui/bl-1.2.3
• dependabot/npm_and_yarn/ui/cached-path-relative-1.0.2
• dependabot/npm_and_yarn/ui/eslint-utils-1.4.3
• dependabot/npm_and_yarn/ui/extend-3.0.2
• dependabot/npm_and_yarn/ui/lodash-4.17.13
• dependabot/npm_and_yarn/ui/lodash-4.17.19
• dependabot/npm_and_yarn/ui/lodash-es-4.17.15
• dependabot/npm_and_yarn/ui/lodash.merge-4.6.2
• dependabot/npm_and_yarn/ui/marked-0.3.19
• dependabot/npm_and_yarn/ui/mixin-deep-1.3.2
• dependabot/npm_and_yarn/ui/node.extend-1.1.8
• dependabot/npm_and_yarn/ui/y18n-3.2.2
• dev
• distributed-locking
• donot_return_task_ack_failed
• dowhile_integ_spec
• dynamic_fork_join_integration_test
• dyno_queue_upgrade
• dyno_upgrade_fix
• enable_aliases_es6
• enforce_external_payload_storage_in_server
• ensure_cancel_task_terminate_workflow
• event_handler_domain_support
• event_processing_metrics
• event_processor_extension
• external_payload_storage_fix
• external_payload_storage_spock_specs
• external_payload_system_task
• external_storage_paths_added_to_summary
• fail_task_on_ack_failure
• fail_task_or_terminate_workflow_on_ack_failure
• feature/MWI-1082-update-system-tasks
• feature/add-version-to-search
• feature/add_api_audit_listener
• feature/add_audit_layer
• feature/add_tests_coverage-AL
• feature/add_workflow_completion_hooks
• feature/add_workflow_completion_listener-AL
• feature/allow_ui_on_localhost_only
• feature/async_complete_subworkflow
• feature/bulk-restart-with-latest-definitions
• feature/change_ui_port
• feature/cleanup_batch_service
• feature/distributed-locking
• feature/dynamic-workflow-search
• feature/event-handler-lookup-task-by-id
• feature/event_queue_config
• feature/fix_http_task_retries
• feature/grpc_and_rest_to_use_shared_service_layer
• feature/locking-service
• feature/mark_parent_as_terminated_on_subworkflow_termination
• feature/queue_message_postpone
• feature/queuedao_resiliency_improvements
• feature/redis-lock
• feature/retart-workflow-with-latest-definition
• feature/search-entire-string-by-default
• feature/split-ui-and-server-http-clients
• feature/stop-initial-loading-of-ui-tables
• feature/task_resiliency
• feature/validation
• feature/workflow_completion_hooks
• feature/workflow_resiliency_test
• finalized_notification_backport
• fix/cannot-see-all-graph-arrows
• fix/decision_task
• fix/disable_enum_validation
• fix/exception
• fix/task_api_workerId_not_required
• fix/update_readme
• fix_archivable_workflows
• fix_cass_event_persistence
• fix_es5rest_archive_test
• fix_exponential_backoff
• fix_inputTemplate_bug
• fix_kitchensink_and_lambda_task
• fix_remove_task_cass
• fix_remove_workflow
• fix_reset_callbacks_api
• fix_restart_workflows
• fix_retry
• fix_skiptask_client_api
• fix_startup
• fix_task_client_large_payloads
• fix_task_copy_retry
• fix_task_poll_npe
• fix_task_result_status
• fix_task_scheduling
• fix_task_update_with_large_payloads
• fix_timeout
• fix_token_supplier_provider
• fix_workflow_retry
• fork_join_integration_tests
• function_tests_cleanup_and_setup
• graceful_shutdown_exec_service
• honor_optional_flag_join_task
• honor_version_running_workflows_search
• hotfix
• hotfix_subworkflow_large_payload_changes
• http_task_mapper
• improve_core_logging
• index_management_es6
• indexing_fixes
• inject_objectmapper_to_httptask
• inject_objectmappers_with_provider
• integration_tests_clean_up
• isolated_task_queue_producer_fix
• jackson_upgrade_to_2.10
• jackson_version_client
• java_client_start_wf_error_metrics
• jsonpath_evaluation_correlationid_eventhandler
• jun-he-patch-1
• jun-he-patch-2
• jun-he-patch-3
• jun/add-poll_timeout_seconds
• jun/fix-es-tests
• jun/inline-subworkflow
• manual_retry_regression
• master
• metadata_dao_refactor
• metric_num_tasks_in_workflow
• minor_cleanup
• minor_cleanup_and_refactoring
• minor_enhancements
• minor_fix
• minor_fixes
• move_indexing_out_of_primary_dao
• move_rate_limiting_out_of_execution_dao
• nkamath_nflx-bulk-restart-fix
• param_replacement_retry_fix
• parmetersutils-fix
• poll_api_error_handling
• prevent_terminal_workflow_status_modification
• python_client_update
• qol_improvements
• queue_wait_time_compute_fix
• rate_limit_contract_change
• refactor
• refactor/disable_schema_version_1
• refactor_client
• refactor_redisson_to_provider
• remove-codecov
• remove_apis_return
• remove_default_domain_fallback
• remove_es_critical_path
• remove_ghost_taskId_from_queue
• remove_grpc_health_lib
• remove_queue_dao_exists
• remove_system_task_worker_inmemory_queue
• remove_workflow_on_restart
• replace-bintray
• replace-hibernate-validator-with-apache-bval
• replace-jcenter
• reset_workflow_upon_restart
• restart_option_with_latest_defs
• retry_timed_out_workflow
• retry_timed_out_workflow_subworkflow
• revert-1348-permanent_failure_should_log_error
• rotate-credentials
• set_metadata_time_service_layer
• simple_workflow_test_cleanup
• sonarsource
• sub_workflow_tests_cleanup
• subwf_output_external_storage
• subworkflow_external_payload_fix
• subworkflow_fork_join_fix
• subworkflow_task_validation
• summary_objects_equals_hashcode
• system_task_external_payload
• task_poll_fix
• task_poll_resiliency
• task_rollback_scheduling_error
• taskresult_object_retry_upload
• terminate_multi_level_sub_workflows
• ui/fix_subworkflowpane_rendering
• updateArchivalbeWorkflowsES5
• update_docs
• update_dynamic_workflow_docs
• update_oss_readme
• update_subworkflow_retry_logic
• update_taskToDomain_mappings
• update_terminate_task
• update_workflow_then_task_for_retry
• upgrade_dyno_queues
• upgrade_jedis_dyno_queues_version
• use_fallback_domain_if_dao_error
• v2.0.0
• v2.0.0-rc5
• v2.0.1
• v2.1.0
• v2.1.1
• v2.10.0
• v2.10.1
• v2.10.2
• v2.11.0
• v2.12.0
• v2.12.1
• v2.12.2
• v2.12.3
• v2.12.4
• v2.12.5
• v2.13.0
• v2.13.1-alpha
• v2.13.2-alpha
• v2.13.3-alpha
• v2.13.4-alpha
• v2.13.4-alpha.1
• v2.13.4-alpha.2
• v2.13.4-alpha.3
• v2.14.0
• v2.14.1
• v2.14.4
• v2.14.6
• v2.14.7
• v2.15.0
• v2.15.0-rc.1
• v2.15.0-rc.2
• v2.15.1
• v2.15.2
• v2.15.2-beta
• v2.15.2-beta.1
• v2.16.0
• v2.16.0-beta.1
• v2.16.0-beta.2
• v2.16.0-beta.3
• v2.16.0-beta.4
• v2.16.0-beta.5
• v2.16.0-beta.6
• v2.16.3
• v2.16.4
• v2.16.4-beta.2
• v2.16.4-hotfix.1
• v2.16.6-alpha
• v2.16.6-alpha.1
• v2.16.6-alpha.2
• v2.17.0
• v2.18.0
• v2.18.0-beta.1
• v2.18.0-beta.2
• v2.18.1-alpha.4
• v2.18.1-alpha.5
• v2.18.1-alpha.6
• v2.19.0
• v2.2.1
• v2.2.2
• v2.20.0
• v2.21.0-alpha
• v2.21.0-hotfix
• v2.21.1
• v2.21.2
• v2.22.0
• v2.22.1
• v2.22.2
• v2.22.2-alpha
• v2.22.3
• v2.22.4
• v2.22.5
• v2.22.5-alpha
• v2.22.6
• v2.22.6-alpha
• v2.23.0
• v2.24.0
• v2.24.1
• v2.24.5-alpha.1
• v2.24.5-alpha.2
• v2.25.0
• v2.25.1
• v2.25.1-alpha
• v2.25.10
• v2.25.11
• v2.25.2-alpha
• v2.25.2-alpha.2
• v2.25.3
• v2.25.4
• v2.25.5
• v2.25.6
• v2.25.7
• v2.25.8
• v2.25.8-beta
• v2.25.8-beta.2
• v2.25.8-beta.3
• v2.25.9
• v2.26.0
• v2.26.0-beta
• v2.26.0-beta.1
• v2.26.1
• v2.26.1-beta
• v2.26.2-beta
• v2.26.2-beta.1
• v2.26.2-beta.2
• v2.27.0
• v2.27.0-beta
• v2.27.0-beta.1
• v2.27.0-beta.2
• v2.27.1
• v2.27.2
• v2.27.3
• v2.27.4
• v2.27.5
• v2.27.6
• v2.28.0
• v2.28.1
• v2.28.2
• v2.28.3
• v2.28.4-alpha
• v2.28.4-alpha.4
• v2.29.0
• v2.29.1
• v2.29.2
• v2.29.3
• v2.30.0
• v2.30.1
• v2.30.2
• v2.30.3
• v2.30.4
• v2.31.0
• v2.31.1
• v2.31.2
• v2.31.3
• v2.31.4
• v2.31.5
• v2.4.0
• v2.5.0
• v2.5.1
• v2.5.2
• v2.5.3
• v2.5.8
• v2.6.0
• v2.6.2
• v2.7.1
• v2.7.2
• v2.7.3
• v2.8.0
• v2.8.2
• v2.8.2-alpha
• v2.8.3
• v2.8.4
• v2.8.5
• v2.9.0
• v2.9.1
• workflow_def_task_def_owner
• workflow_spec
• workflow_type_correlation_id_fix

Build # 3741

Build Type

push

travis-ci-com

Committed by kishorebanala

Commit Message

Add postpone with a default duration to task poll, when task exceeds concurrent execution limits.

Add postpone with a default duration to execute system task, when task exceeds concurrent execution or rate limits.

Added testsfor concurrent execution and rate limiting.

Added property to configure Task queue message postpone duration.

Run Details

11402 of 16294 relevant lines covered (69.98%)

0.7 hits per line