Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/taskforcesh/bullmq
/ functions
Functions
3,768 in github.com/taskforcesh/bullmq
⨍
Functions
3,768
◇
Types & classes
487
↳
Endpoints
8
Method
setUp
(self)
python/tests/worker_disconnect_test.py:76
Method
setUp
(self)
python/tests/priority_test.py:21
Method
setUp
(self)
python/tests/worker_test.py:24
Method
setUp
()
php/tests/QueueTest.php:21
Function
should_add_bulk_and_process_flows
()
rust/tests/flow_test.rs:3309
Function
should_add_bulk_flows
()
rust/tests/flow_test.rs:898
Function
should_add_jobs_that_do_not_exist_continually
()
rust/tests/flow_test.rs:7365
Function
should_add_meta_key_to_both_parents_and_children
()
rust/tests/flow_test.rs:967
Function
should_allow_parent_opts_on_the_root_job
()
rust/tests/flow_test.rs:1835
Function
should_allow_parent_opts_on_the_root_job_add_bulk
()
rust/tests/flow_test.rs:9171
Function
should_allow_passing_custom_job_id_in_options
()
rust/tests/flow_test.rs:254
Function
should_begin_with_attempts_made_as_one_in_flow
()
rust/tests/flow_test.rs:7492
Function
should_continue_parent_on_failure
()
rust/tests/flow_test.rs:1209
Function
should_deduplicate_root_parent_job_with_same_dedup_id
()
rust/tests/flow_test.rs:4143
Function
should_error_when_job_already_has_parent
()
rust/tests/flow_test.rs:4795
Function
should_error_when_removing_dependency_with_missing_child
()
rust/tests/flow_test.rs:4043
Function
should_error_when_removing_dependency_with_missing_parent
()
rust/tests/flow_test.rs:4002
Function
should_fail_parent_and_grandparent_when_moving_to_waiting_children
()
rust/tests/flow_test.rs:7924
Function
should_fail_parent_when_child_with_fail_parent_on_failure_fails
()
rust/tests/flow_test.rs:580
Function
should_fail_parent_when_child_with_fpof_failed_before_move_to_waiting_children
()
rust/tests/flow_test.rs:4531
Function
should_fail_parent_with_last_error
()
rust/tests/flow_test.rs:8111
Function
should_fail_parent_with_pending_dependencies_error
()
rust/tests/flow_test.rs:7594
Function
should_fail_parent_with_pending_dependencies_error_fpof_child
()
rust/tests/flow_test.rs:7689
Method
should_fetch_next
Whether the finishing script should also fetch the next job in the same round-trip. Mirrors the Node.js `fetchNextCallback`.
rust/src/worker.rs:1234
Function
should_get_a_flow_tree
()
rust/tests/flow_test.rs:4864
Function
should_get_a_flow_tree_using_default_prefix
()
rust/tests/flow_test.rs:6633
Function
should_get_dependencies_count_with_remove_on_fail
()
rust/tests/flow_test.rs:1613
Function
should_get_ignored_children_failures_via_job
()
rust/tests/flow_test.rs:9485
Function
should_get_paginated_processed_dependencies_keys
()
rust/tests/flow_test.rs:9067
Function
should_get_part_of_flow_tree
()
rust/tests/flow_test.rs:5160
Function
should_get_unprocessed_dependencies
()
rust/tests/flow_test.rs:2173
Function
should_ignore_missing_child_jobs_when_loading_flow
()
rust/tests/flow_test.rs:5027
Function
should_ignore_parent_when_multiple_cpof_children_fail
()
rust/tests/flow_test.rs:3430
Function
should_keep_children_results_in_parent_when_remove_on_complete
()
rust/tests/flow_test.rs:1404
Function
should_keep_children_results_in_parent_with_remove_on_complete_age
()
rust/tests/flow_test.rs:8572
Function
should_keep_parent_waiting_when_removing_one_of_many_dependencies
()
rust/tests/flow_test.rs:3911
Function
should_move_children_to_delayed
()
rust/tests/flow_test.rs:2290
Function
should_move_grandparent_to_wait_with_idof_and_fpof_cascade
()
rust/tests/flow_test.rs:3700
Function
should_move_grandparent_to_wait_with_rdof_and_fpof_cascade
()
rust/tests/flow_test.rs:3575
Function
should_move_parent_to_delayed_after_child_fails_with_cpof
()
rust/tests/flow_test.rs:2983
Function
should_move_parent_to_delayed_after_children_complete
()
rust/tests/flow_test.rs:3205
Function
should_move_parent_to_failed_in_deep_chain_with_fpof
()
rust/tests/flow_test.rs:2609
Function
should_move_parent_to_failed_when_child_fails_parent_delayed
()
rust/tests/flow_test.rs:8229
Function
should_move_parent_to_failed_when_child_fails_parent_prioritized
()
rust/tests/flow_test.rs:8402
Function
should_move_parent_to_prioritized_after_child_fails_with_cpof
()
rust/tests/flow_test.rs:3092
Function
should_move_parent_to_wait_if_child_already_completed
()
rust/tests/flow_test.rs:7027
Function
should_move_parent_to_wait_when_ignore_dependency_on_failure
()
rust/tests/flow_test.rs:656
Function
should_move_parent_to_wait_when_last_child_removes_dependency
()
rust/tests/flow_test.rs:3827
Function
should_move_parent_to_wait_when_remove_dependency_on_failure
()
rust/tests/flow_test.rs:738
Function
should_move_parent_to_wait_when_remove_on_fail_child_fails
()
rust/tests/flow_test.rs:2903
Function
should_move_parent_to_wait_with_ignored_children_failures
()
rust/tests/flow_test.rs:1705
Function
should_move_parent_to_wait_without_getting_stuck_with_remove_on_fail_child
()
rust/tests/flow_test.rs:6853
Function
should_not_process_parent_if_child_fails
()
rust/tests/flow_test.rs:497
Function
should_not_process_parent_until_queue_is_unpaused
()
rust/tests/flow_test.rs:2059
Function
should_not_remove_children_when_remove_without_children
()
rust/tests/flow_test.rs:5561
Function
should_not_remove_completed_children_with_remove_unprocessed
()
rust/tests/flow_test.rs:5751
Function
should_not_remove_locked_job_in_tree
()
rust/tests/flow_test.rs:6123
Function
should_not_restore_parent_reference_after_remove_child_dependency
()
rust/tests/flow_test.rs:7137
Function
should_only_move_parent_to_wait_when_all_children_removed
()
rust/tests/flow_test.rs:5490
Function
should_process_a_chain_of_jobs
()
rust/tests/flow_test.rs:312
Function
should_process_children_before_parent_prioritizing_per_queue_name
()
rust/tests/flow_test.rs:7186
Function
should_process_children_before_parent_with_children_values
()
rust/tests/flow_test.rs:1488
Function
should_process_children_before_parent_with_default_job_options
()
rust/tests/flow_test.rs:7779
Function
should_process_children_before_the_parent
()
rust/tests/flow_test.rs:59
Function
should_process_children_respecting_priority_with_queues_options
()
rust/tests/flow_test.rs:8695
Function
should_process_children_with_priority
()
rust/tests/flow_test.rs:1100
Function
should_process_parent_added_while_child_is_active
()
rust/tests/flow_test.rs:6938
Function
should_process_parent_after_child_fails_with_unprocessed_siblings
()
rust/tests/flow_test.rs:2761
Function
should_process_parent_when_child_with_remove_on_fail_fails
()
rust/tests/flow_test.rs:820
Function
should_process_parent_when_children_is_an_empty_array
()
rust/tests/flow_test.rs:198
Function
should_process_parent_with_delay_after_children_complete
()
rust/tests/flow_test.rs:1018
Function
should_process_parent_with_multiple_children_where_some_fail
()
rust/tests/flow_test.rs:1292
Function
should_propagate_child_loading_errors_when_loading_flow
()
rust/tests/flow_test.rs:5085
Function
should_propagate_get_flow_dependency_errors
()
rust/tests/flow_test.rs:4957
Function
should_reject_colon_in_flow_queue_names
()
rust/tests/flow_test.rs:5254
Function
should_remove_all_children_after_processing
()
rust/tests/flow_test.rs:5882
Function
should_remove_all_children_when_removing_parent
()
rust/tests/flow_test.rs:5325
Function
should_remove_all_children_when_removing_parent_with_unsuccessful_children
()
rust/tests/flow_test.rs:9306
Function
should_remove_child_and_move_parent_to_wait
()
rust/tests/flow_test.rs:5404
Function
should_remove_children_but_not_grandparent
()
rust/tests/flow_test.rs:5996
Function
should_remove_from_parent_deps_and_move_to_wait
()
rust/tests/flow_test.rs:6219
Function
should_remove_parent_when_child_moved_to_failed_remove_on_fail
()
rust/tests/flow_test.rs:8898
Function
should_remove_processed_data_when_parent_remove_on_complete
()
rust/tests/flow_test.rs:6722
Function
should_remove_unprocessed_children
()
rust/tests/flow_test.rs:5646
Function
should_report_is_waiting_children_on_parent
()
rust/tests/flow_test.rs:9442
Function
should_retry_child_with_fixed_backoff_in_flow
()
rust/tests/flow_test.rs:1964
Function
should_return_deduplicated_id_for_nested_flows
()
rust/tests/flow_test.rs:4220
Function
should_return_deduplicated_ids_from_add_bulk
()
rust/tests/flow_test.rs:4300
Function
should_return_deduplicated_root_job_id_when_flow_has_no_children
()
rust/tests/flow_test.rs:4086
Function
should_return_error_when_some_add_bulk_commands_fail
()
rust/tests/flow_test.rs:6526
Function
should_return_same_deduplicated_id_for_concurrent_add_calls
()
rust/tests/flow_test.rs:4355
Function
should_start_processing_parent_after_child_fails_with_continue
()
rust/tests/flow_test.rs:2398
Function
should_throw_error_when_add_with_non_existing_parent
()
rust/tests/flow_test.rs:6586
Function
should_update_parent_deps_when_retrying_completed_child
()
rust/tests/flow_test.rs:6407
Function
should_update_parent_deps_when_retrying_failed_child
()
rust/tests/flow_test.rs:6297
Function
should_use_custom_prefix_to_add_jobs
()
rust/tests/flow_test.rs:2504
Function
should_wait_children_as_one_step_of_parent_job
()
rust/tests/flow_test.rs:4411
Function
should_wait_children_as_one_step_with_grandchildren
()
rust/tests/flow_test.rs:4652
Method
signalCode
()
src/classes/child.ts:67
Method
size_limit
Reject the job if its serialized payload exceeds `bytes` UTF-8 bytes.
rust/src/queue.rs:2784
← previous
next →
2,901–3,000 of 3,768, ranked by callers