aboutsummaryrefslogtreecommitdiffstats
path: root/activejob/lib
Commit message (Collapse)AuthorAgeFilesLines
* Merge pull request #19425 from wvengen/feature/activejob-priority-masterRafael Mendonça França2015-09-256-4/+62
|\ | | | | Add job priorities to ActiveJob
| * Add job priorities to ActiveJobwvengen2015-09-176-4/+62
| |
* | Replaced `ThreadSafe::Map` with successor `Concurrent::Map`.Jerry D'Antonio2015-09-191-2/+1
|/ | | | | | | The thread_safe gem is being deprecated and all its code has been merged into the concurrent-ruby gem. The new class, Concurrent::Map, is exactly the same as its predecessor except for fixes to two bugs discovered during the merge.
* Properly log nested parameters to Active JobMarek Pieczyk2015-09-081-1/+15
| | | | Refactor arguments logging method for Active Job
* Initial implementation of ActiveJob AsyncAdapter.Jerry D'Antonio2015-08-254-0/+108
|
* Fix typo on method nameRafael Mendonça França2015-08-161-3/+3
| | | | [Robin Dupret]
* implement `provider_job_id` for `queue_classic`.Yves Senn2015-08-131-2/+6
| | | | | | The latest, currently unreleased, version of queue_classic is required for this to work. See https://github.com/QueueClassic/queue_classic/pull/262 for more details.
* Make assert_enqueued_with and assert_performed_with returns the matched jobJean Boussier2015-08-101-2/+11
|
* Merge pull request #21145 from toydestroyer/masterYves Senn2015-08-061-15/+14
|\ | | | | | | | | | | [ci skip] Documentation: update queue_classic info in Active Job adapters list
| * Documentation: update queue_classic info in Active Job adapters listSergey Toy2015-08-061-4/+3
|/
* Merge pull request #20800 from xijo/make_active_job_locale_awareKasper Timm Hansen2015-08-043-1/+19
|\ | | | | Make ActiveJob locale aware
| * Fixes #20799Johannes Opper2015-08-043-1/+19
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | When `#perform_later` is called the locale isn't stored on the queue, which results in a locale reset when the job is performed. An example of the problem: I18n.locale = 'de' HelloJob.perform_now # german message, correct but I18n.locale = 'de' HelloJob.perform_later # english message, incorrect This PR attaches the current I18n.locale to every job during the serialization process. It is then restored during deserialization and used to perform the job with the correct locale. It falls back to the default locale if no serialized locale is found in order to provide backward compatibility with previously stored jobs. It is not necessary to clear the queue for the update.
* | Add `:nodoc:` for internal testing methods [ci skip]Robin Dupret2015-07-281-2/+2
|/
* Improve error message when serializing unsaved records for jobsFaraz Yashar2015-06-281-7/+14
|
* [ci skip] Add `.`yui-knk2015-06-101-1/+1
|
* [skip ci] Add documentation for QueueAdapter::queue_adapterAnton Davydov2015-06-021-0/+2
|
* [skip ci] Update documentation for QueueAdapters::lookupAnton Davydov2015-06-011-0/+4
|
* doc changes for readability [ci skip]Gourav Tiwari2015-05-191-2/+2
|
* Merge pull request #20064 from kddeisz/qu_provider_job_idRafael Mendonça França2015-05-081-1/+5
|\ | | | | Provide provider_job_id to qu adapter.
| * Provide provider_job_id to qu adapter.Kevin Deisz2015-05-071-1/+5
| | | | | | | | Further work to provide provider_job_id for queue adapters.
* | Refactor sidekiq adapter enqueue and enqueue_at methodsMehmet Emin İNAÇ2015-05-081-6/+2
|/
* Make que report back its job_id to provider_job_idJeroen van Baarsen2015-05-071-2/+6
| | | | Signed-off-by: Jeroen van Baarsen <jeroenvanbaarsen@gmail.com>
* Let Sidekiq set provider_job_idJeroen van Baarsen2015-05-071-2/+6
| | | | | | | | | | When a job is added to Sidekiq by ActiveJob, make sure we still can get the original job_id provider by Sidekiq. We do this by adding the sidekiq jid to provider_job_id field on the job object. Partly fixes #18821 Signed-off-by: Jeroen van Baarsen <jeroenvanbaarsen@gmail.com>
* Get provider_job_id from DelayedJobKevin Deisz2015-05-052-2/+9
| | | | | When queueing with DelayedJob, get the id of the job instance and report it back to ActiveJob as provider_job_id.
* Merge pull request #19498 from chanks/activejob-que-remove-named-queuesRafael Mendonça França2015-05-031-2/+2
|\ | | | | ActiveJob: Stop using Que's named queues.
| * Stop using Que's named queues in its ActiveJob adapter.Chris Hanks2015-03-241-2/+2
| |
* | match a expected value with message of `assert_equal` in AJ helper methodsyuuji.yaginuma2015-05-011-2/+2
| |
* | Add doc for original_exception in ActiveJob::DeserializationError [ci skip]Zachary Scott2015-04-291-0/+2
| |
* | Add initial doc for Core in AJ [ci skip]Zachary Scott2015-04-291-0/+2
| |
* | Add initial doc for Enqueuing module [ci skip]Zachary Scott2015-04-291-0/+1
| |
* | Rails should be nodoc'd here [ci skip]Zachary Scott2015-04-291-1/+1
| |
* | Add missing error messages for sucker_punch, sneakers and qu activejob ↵Mehmet Emin İNAÇ2015-04-294-4/+4
| | | | | | | | | | | | | | | | | | | | adapters [ci skip] fix error message change raise to use rails conventions fix misspells
* | nodoc private internal constants from ActiveJob::ArgumentsZachary Scott2015-04-261-0/+5
| |
* | Remove nonexistent adapterRafael Mendonça França2015-04-231-1/+0
| | | | | | | | | | | | Closes #19866 [ci skip]
* | Fix a few typos and wrap some lines [ci skip]Robin Dupret2015-04-121-9/+17
| |
* | Copy edits for QueueAdapters docs to fix #17765 [ci skip]Zachary Scott2015-04-101-18/+18
| |
* | [ci skip] Adds documentation explaining table labels for Active Job ↵KingsleyKelly2015-04-091-7/+47
| | | | | | | | QueueAdapters table in docs.
* | [ci skip] Adds rdoc for priority explaining what the labels in the table means.KingsleyKelly2015-04-061-0/+16
| |
* | Merge pull request #19034 from jvanbaarsen/explicit-job-base-classMatthew Draper2015-03-302-2/+1
|\ \ | | | | | | | | | Add explicit base class for ActiveJob jobs
| * | Add explicit base class for ActiveJob jobsJeroen van Baarsen2015-03-232-2/+1
| | | | | | | | | | | | | | | | | | | | | | | | * Jobs generated now inherent from ApplicationJob * ApplicationJob inherents from ActiveJob::Base * Added entry to changelog Signed-off-by: Jeroen van Baarsen <jeroenvanbaarsen@gmail.com>
* | | Pass wrapped class name to Sidekiq for logging purposesMike Perham2015-03-231-7/+9
| |/ |/| | | | | | | | | | | Sidekiq logs the name of the job class being performed. Because ActiveJob wraps the class, this means every job logs as an AJ::JobWrapper instead of the actual class name. Will help fix mperham/sidekiq#2248
* | Move Adapter to private constantSemyon Pupkov2015-03-161-0/+1
|/
* `QueueAdapters` does the lookupTamir Duberstein2015-03-122-5/+9
|
* Use a more conservative `const_get` over `constantize`Tamir Duberstein2015-03-121-1/+1
|
* `ActiveJob::Base#queue_adapter` is now a `class_attribute`Tamir Duberstein2015-03-112-12/+36
| | | | | | This allows different `queue_adapters` to be used in each `ActiveJob` class heirarchy. Previously, all subclasses used a single global queue adapter.
* `ActiveJob::QueueAdapters::*` are no longer singletonsTamir Duberstein2015-03-1114-148/+145
|
* Fix leaky `only: …` option for Active Job assertionsJeremy Kemper2015-03-061-9/+15
| | | | | | | The filter was set on the pseudo-global TestAdapter but not restored to its original value. See e818f65770fe115ab1cc7fbacc0e7e94d92af6a4
* Avoid creating an extra hash on the job test adapterCarlos Antonio da Silva2015-02-241-1/+1
|
* `ActiveJob::QueueAdapters::TestAdapter` is now a singletonTamir Duberstein2015-02-233-30/+30
| | | | | | | | | Since `ActiveJob::TestHelper` globally sets `ActiveJob::Base.queue_adapter` on setup, there is no benefit in instantiating a new `TestAdapter` per tests. The original rationale was to allow parallel tests to run without interference, but since they'd all mutate the global `ActiveJob::Base.queue_adapter`, that was never realized.
* Add an `:only` option to `perform_enqueued_jobs` to filter jobs based onMichael Ryan2015-02-062-18/+74
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | type. This allows specific jobs to be tested, while preventing others from being performed unnecessarily. Example: def test_hello_job assert_performed_jobs 1, only: HelloJob do HelloJob.perform_later('jeremy') LoggingJob.perform_later end end An array may also be specified, to support testing multiple jobs. Example: def test_hello_and_logging_jobs assert_nothing_raised do assert_performed_jobs 2, only: [HelloJob, LoggingJob] do HelloJob.perform_later('jeremy') LoggingJob.perform_later('stewie') RescueJob.perform_later('david') end end end Fixes #18802. Trim space and document :only option.